nl.nn.adapterframework.testtool

Class ListenerMessageHandler<M>

java.lang.Object

nl.nn.adapterframework.testtool.ListenerMessageHandler<M>

All Implemented Interfaces:

IMessageHandler<M>

public class ListenerMessageHandler<M>
extends Object
implements IMessageHandler<M>

Message handler for JavaListener and WebServiceListener.

Author:

Jaco de Groot, Niels Meijer

Constructor Summary

Constructors

Constructor and Description
ListenerMessageHandler()

Method Summary

Modifier and Type	Method and Description
Message	formatException(String extraInfo, String arg1, Message arg2, Throwable arg3) Formats any exception thrown by any of the above methods to a message that can be returned.
ListenerMessage	getRequestMessage() Attempt to retrieve a ListenerMessage.
ListenerMessage	getRequestMessage(long timeout) Attempt to retrieve a ListenerMessage with timeout in ms.
ListenerMessage	getResponseMessage() Attempt to retrieve a ListenerMessage.
ListenerMessage	getResponseMessage(long timeout) Attempt to retrieve a ListenerMessage with timeout in ms.
void	processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, boolean duplicatesAlreadyChecked) Will use listener to perform IListener.extractMessage(nl.nn.adapterframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(nl.nn.adapterframework.core.PipeLineResult, nl.nn.adapterframework.receivers.RawMessageWrapper<M>, nl.nn.adapterframework.core.PipeLineSession)
void	processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, long waitingTime, boolean duplicatesAlreadyChecked) Same as IMessageHandler.processRawMessage(IListener,RawMessageWrapper,PipeLineSession, boolean), but now updates IdleStatistics too
Message	processRequest(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Alternative to functions above, will NOT use IListener.extractMessage(nl.nn.adapterframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>).
void	putResponseMessage(ListenerMessage listenerMessage)
void	setRequestTimeOut(int timeout)
void	setResponseTimeOut(int timeout)
void	setTimeout(long defaultTimeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ListenerMessageHandler

public ListenerMessageHandler()

Method Detail

processRequest

public Message processRequest(IListener<M> origin,
                              RawMessageWrapper<M> rawMessage,
                              Message message,
                              PipeLineSession session)
                       throws ListenerException

Description copied from interface: IMessageHandler

Alternative to functions above, will NOT use IListener.extractMessage(nl.nn.adapterframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>). Used by PushingListeners.

Specified by:

processRequest in interface IMessageHandler<M>

Throws:

ListenerException

getRequestMessage

public ListenerMessage getRequestMessage()

Attempt to retrieve a ListenerMessage. Returns NULL if none is present

getRequestMessage

public ListenerMessage getRequestMessage(long timeout)
                                  throws TimeoutException

Attempt to retrieve a ListenerMessage with timeout in ms. Returns TimeOutException if non is present

Throws:

TimeoutException

getResponseMessage

public ListenerMessage getResponseMessage()

Attempt to retrieve a ListenerMessage. Returns NULL if none is present

getResponseMessage

public ListenerMessage getResponseMessage(long timeout)
                                   throws TimeoutException

Attempt to retrieve a ListenerMessage with timeout in ms. Returns TimeOutException if non is present

Throws:

TimeoutException

putResponseMessage

public void putResponseMessage(ListenerMessage listenerMessage)

setTimeout

public void setTimeout(long defaultTimeout)

setRequestTimeOut

public void setRequestTimeOut(int timeout)

setResponseTimeOut

public void setResponseTimeOut(int timeout)

processRawMessage

public void processRawMessage(IListener<M> origin,
                              RawMessageWrapper<M> rawMessage,
                              PipeLineSession threadContext,
                              boolean duplicatesAlreadyChecked)
                       throws ListenerException

Description copied from interface: IMessageHandler

Will use listener to perform IListener.extractMessage(nl.nn.adapterframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(nl.nn.adapterframework.core.PipeLineResult, nl.nn.adapterframework.receivers.RawMessageWrapper<M>, nl.nn.adapterframework.core.PipeLineSession)

Specified by:

processRawMessage in interface IMessageHandler<M>

Throws:

ListenerException

processRawMessage

public void processRawMessage(IListener<M> origin,
                              RawMessageWrapper<M> rawMessage,
                              PipeLineSession threadContext,
                              long waitingTime,
                              boolean duplicatesAlreadyChecked)
                       throws ListenerException

Description copied from interface: IMessageHandler

Same as IMessageHandler.processRawMessage(IListener,RawMessageWrapper,PipeLineSession, boolean), but now updates IdleStatistics too

Specified by:

processRawMessage in interface IMessageHandler<M>

Throws:

ListenerException

formatException

public Message formatException(String extraInfo,
                               String arg1,
                               Message arg2,
                               Throwable arg3)

Description copied from interface: IMessageHandler

Formats any exception thrown by any of the above methods to a message that can be returned. Can be used if the calling system has no other way of returning the exception to the caller.

Specified by:

formatException in interface IMessageHandler<M>