public class ListenerMessageHandler<M> extends Object implements IMessageHandler<M>
Constructor and Description |
---|
ListenerMessageHandler() |
public Message processRequest(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) throws ListenerException
IMessageHandler
IListener.extractMessage(nl.nn.adapterframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)
. Used by PushingListeners.processRequest
in interface IMessageHandler<M>
ListenerException
public ListenerMessage getRequestMessage()
ListenerMessage
. Returns NULL if none is presentpublic ListenerMessage getRequestMessage(long timeout) throws TimeoutException
ListenerMessage
with timeout in ms. Returns TimeOutException if non is presentTimeoutException
public ListenerMessage getResponseMessage()
ListenerMessage
. Returns NULL if none is presentpublic ListenerMessage getResponseMessage(long timeout) throws TimeoutException
ListenerMessage
with timeout in ms. Returns TimeOutException if non is presentTimeoutException
public void putResponseMessage(ListenerMessage listenerMessage)
public void setTimeout(long defaultTimeout)
public void setRequestTimeOut(int timeout)
public void setResponseTimeOut(int timeout)
public void processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, boolean duplicatesAlreadyChecked) throws ListenerException
IMessageHandler
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)
processRawMessage
in interface IMessageHandler<M>
ListenerException
public void processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, long waitingTime, boolean duplicatesAlreadyChecked) throws ListenerException
IMessageHandler
IMessageHandler.processRawMessage(IListener,RawMessageWrapper,PipeLineSession, boolean)
, but now updates IdleStatistics tooprocessRawMessage
in interface IMessageHandler<M>
ListenerException
public Message formatException(String extraInfo, String arg1, Message arg2, Throwable arg3)
IMessageHandler
formatException
in interface IMessageHandler<M>
Copyright © 2023 Frank!Framework. All rights reserved.