Interface IPushingListener<M>

Type Parameters:

M - the raw message type

All Superinterfaces:

org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.Aware, FrankElement, HasApplicationContext, HasName, IConfigurable, IListener<M>, IScopeProvider, NameAware

All Known Subinterfaces:

IPortConnectedListener<M>, ISapListener<F>

All Known Implementing Classes:

AmqpListener, ApiListener, BisJmsListener, CmisEventListener, EsbJmsListener, FrankListener, FxfListener, JavaListener, JmsListener, MqttListener, PushingJmsListener, PushingListenerAdapter, RestListener, SapListener, SapListener, SapListenerImpl, TibcoLogJmsListener, WebServiceListener

public interface IPushingListener<M>
extends IListener<M>

Defines listening behaviour of message driven receivers.

Since:

4.2

Author:

Gerrit van Brakel

Method Summary

Modifier and Type	Method	Description
void	setExceptionListener(IbisExceptionListener listener)	Set a (single) listener that will be notified of any exceptions.
void	setHandler(IMessageHandler<M> handler)	Set the handler that will do the processing of the message.
RawMessageWrapper<M>	wrapRawMessage(M rawMessage, PipeLineSession session)	Wrap a raw message in a MessageWrapper.

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface FrankElement

addConfigWarning

Methods inherited from interface HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface HasName

getName

Methods inherited from interface IConfigurable

configure

Methods inherited from interface IListener

afterMessageProcessed, extractMessage, start, stop

Methods inherited from interface NameAware

setName

Method Details

setHandler

void setHandler(IMessageHandler<M> handler)

Set the handler that will do the processing of the message. Each of the received messages must be pushed through handler.processMessage()

setExceptionListener

void setExceptionListener(IbisExceptionListener listener)

Set a (single) listener that will be notified of any exceptions. The listener should use this listener to notify the receiver of any exception that occurs outside the processing of a message.

wrapRawMessage

RawMessageWrapper<M> wrapRawMessage(M rawMessage,
 PipeLineSession session)
                             throws ListenerException

Wrap a raw message in a MessageWrapper. Populate PipeLineSession with properties from the message.

Parameters:

rawMessage - The raw message data, unwrapped

session - PipeLineSession to populate with properties from the message.

Returns:

Wrapped raw message

Throws:

ListenerException - If any exception occurs during wrapping, a ListenerException is thrown.