AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>
clear, clone, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, forEach, get, getOrDefault, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values
equals, hashCode, toString
finalize, getClass, notify, notifyAll, wait, wait, wait
clear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values
public static QueueWrapper create(IConfigurable configurable)
public PipeLineSession getSession()
public ListenerMessageHandler getMessageHandler()
public void setSenderThread(SenderThread senderThread)
public SenderThread getSenderThread()
public void removeSenderThread()
public QueueWrapper invokeSetters(Properties queueProperties)
public QueueWrapper invokeSetters(int defaultTimeout, Properties properties)
public static Map<String,Object> createParametersMapFromParamProperties(Properties properties, boolean createParameterObjects, PipeLineSession session)
public IConfigurable get()
public static QueueWrapper createQueue(String className, Properties queueProperties, int defaultTimeout, String correlationId)
public void configure() throws ConfigurationException
configure
in interface Queue
ConfigurationException
public void open() throws ConfigurationException
open
in interface Queue
ConfigurationException
public int executeWrite(String stepDisplayName, String fileContent, String correlationId, Map<String,Object> parameters) throws TimeoutException, SenderException, ListenerException
executeWrite
in interface Queue
TimeoutException
SenderException
ListenerException
public String executeRead(String step, String stepDisplayName, Properties properties, String fileName, String fileContent) throws SenderException, IOException, TimeoutException, ListenerException
executeRead
in interface Queue
SenderException
IOException
TimeoutException
ListenerException
Copyright © 2023 Frank!Framework. All rights reserved.