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>

public class QueueWrapper
extends HashMap<String,Object>

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)
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

equals, hashCode

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

Throws:

ConfigurationException

open

public void open()
          throws ConfigurationException

Throws:

ConfigurationException

close

public void close()
           throws Exception

Throws:

Exception