nl.nn.adapterframework.testtool.queues

Class QueueWrapper

java.lang.Object

java.util.AbstractMap<K,V>

java.util.HashMap<String,Object>

nl.nn.adapterframework.testtool.queues.QueueWrapper

All Implemented Interfaces:

Serializable, Cloneable, Map<String,Object>, Queue

public class QueueWrapper
extends HashMap<String,Object>
implements Queue

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure()
static QueueWrapper	create(IConfigurable configurable)
static Map<String,Object>	createParametersMapFromParamProperties(Properties properties, boolean createParameterObjects, PipeLineSession session)
static QueueWrapper	createQueue(String className, Properties queueProperties, int defaultTimeout, String correlationId)
String	executeRead(String step, String stepDisplayName, Properties properties, String fileName, String fileContent)
int	executeWrite(String stepDisplayName, String fileContent, String correlationId, Map<String,Object> parameters)
IConfigurable	get()
ListenerMessageHandler	getMessageHandler()
SenderThread	getSenderThread()
PipeLineSession	getSession()
QueueWrapper	invokeSetters(int defaultTimeout, Properties properties)
QueueWrapper	invokeSetters(Properties queueProperties)
void	open()
void	removeSenderThread()
void	setSenderThread(SenderThread senderThread)

Methods inherited from class java.util.HashMap

clear, clone, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, forEach, get, getOrDefault, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values

Methods inherited from class java.util.AbstractMap

equals, hashCode, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

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

Method Detail

create

public static QueueWrapper create(IConfigurable configurable)

getSession

public PipeLineSession getSession()

getMessageHandler

public ListenerMessageHandler getMessageHandler()

setSenderThread

public void setSenderThread(SenderThread senderThread)

getSenderThread

public SenderThread getSenderThread()

removeSenderThread

public void removeSenderThread()

invokeSetters

public QueueWrapper invokeSetters(Properties queueProperties)

invokeSetters

public QueueWrapper invokeSetters(int defaultTimeout,
                                  Properties properties)

createParametersMapFromParamProperties

public static Map<String,Object> createParametersMapFromParamProperties(Properties properties,
                                                                        boolean createParameterObjects,
                                                                        PipeLineSession session)

get

public IConfigurable get()

createQueue

public static QueueWrapper createQueue(String className,
                                       Properties queueProperties,
                                       int defaultTimeout,
                                       String correlationId)

configure

public void configure()
               throws ConfigurationException

Specified by:

configure in interface Queue

Throws:

ConfigurationException

open

public void open()
          throws ConfigurationException

Specified by:

open in interface Queue

Throws:

ConfigurationException

close

public void close()
           throws Exception

Throws:

Exception

executeWrite

public int executeWrite(String stepDisplayName,
                        String fileContent,
                        String correlationId,
                        Map<String,Object> parameters)
                 throws TimeoutException,
                        SenderException,
                        ListenerException

Specified by:

executeWrite in interface Queue

Throws:

TimeoutException

SenderException

ListenerException

executeRead

public String executeRead(String step,
                          String stepDisplayName,
                          Properties properties,
                          String fileName,
                          String fileContent)
                   throws SenderException,
                          IOException,
                          TimeoutException,
                          ListenerException

Specified by:

executeRead in interface Queue

Throws:

SenderException

IOException

TimeoutException

ListenerException