Package org.frankframework.larva

Class ListenerMessageHandler<M>

java.lang.Object

org.frankframework.larva.ListenerMessageHandler<M>

All Implemented Interfaces:

IMessageHandler<M>

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

Message handler for JavaListener and WebServiceListener. Only used for PushingListeners.

Author:

Niels Meijer

Constructor Summary

Constructors

Constructor	Description
ListenerMessageHandler(long defaultTimeout)

Method Summary

Modifier and Type	Method	Description
ListenerMessage	getRequestMessageOrNull()	Attempt to retrieve a ListenerMessage.
ListenerMessage	getRequestMessageWithDefaultTimeout()
ListenerMessage	getResponseMessageOrNull()	Attempt to retrieve a ListenerMessage.
void	processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, boolean duplicatesAlreadyChecked)	Will use listener to perform IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession) TODO Shouldn't this be a IPullingListener or at least an interface that contains IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession).
Message	processRequest(IPushingListener<M> origin, MessageWrapper<M> rawMessage, PipeLineSession session)	Alternative to functions above, will NOT use IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) as both input and output are a Message.
void	putResponseMessage(ListenerMessage listenerMessage)
void	setRequestTimeOut(int timeout)
void	setResponseTimeOut(int timeout)
void	setTimeout(long timeout)

Methods inherited from class java.lang.Object

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

Constructor Details

ListenerMessageHandler

public ListenerMessageHandler(long defaultTimeout)

Method Details

processRequest

public Message processRequest(IPushingListener<M> origin,
 MessageWrapper<M> rawMessage,
 PipeLineSession session)
                       throws ListenerException

Description copied from interface: IMessageHandler

Alternative to functions above, will NOT use IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) as both input and output are a Message.

Specified by:

processRequest in interface IMessageHandler<M>

Throws:

ListenerException

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(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession) TODO Shouldn't this be a IPullingListener or at least an interface that contains IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession). Then listeners should implement either A or B, and don't have to worry about implementing methods are will never be used...

Specified by:

processRawMessage in interface IMessageHandler<M>

Throws:

ListenerException

getRequestMessageOrNull

@Nullable
public ListenerMessage getRequestMessageOrNull()

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

getRequestMessageWithDefaultTimeout

@Nonnull
public ListenerMessage getRequestMessageWithDefaultTimeout()
                                                    throws TimeoutException

Throws:

TimeoutException

getResponseMessageOrNull

@Nullable
public ListenerMessage getResponseMessageOrNull()

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

putResponseMessage

public void putResponseMessage(ListenerMessage listenerMessage)

setTimeout

public void setTimeout(long timeout)

setRequestTimeOut

public void setRequestTimeOut(int timeout)

setResponseTimeOut

public void setResponseTimeOut(int timeout)