nl.nn.adapterframework.core

Interface IPostboxListener<M>

All Superinterfaces:

org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.Aware, IConfigurable, IConfigurationAware, IListener<M>, INamedObject, IPullingListener<M>, IScopeProvider

All Known Implementing Classes:

PullingJmsListener

public interface IPostboxListener<M>
extends IPullingListener<M>

The IPostboxListener is responsible for querying a message from a postbox.

Author:

John Dekker

Method Summary

Modifier and Type	Method and Description
RawMessageWrapper<M>	retrieveRawMessage(String messageSelector, Map<String,Object> threadContext) Retrieves the first message found from queue or other channel, that matches the specified messageSelector.

Methods inherited from interface nl.nn.adapterframework.core.IPullingListener

closeThread, getRawMessage, openThread

Methods inherited from interface nl.nn.adapterframework.core.IListener

afterMessageProcessed, close, configure, extractMessage, open

Methods inherited from interface nl.nn.adapterframework.core.INamedObject

getName, setName

Methods inherited from interface nl.nn.adapterframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface nl.nn.adapterframework.core.IScopeProvider

getConfigurationClassLoader

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Method Detail

retrieveRawMessage

RawMessageWrapper<M> retrieveRawMessage(String messageSelector,
                                        Map<String,Object> threadContext)
                                 throws ListenerException,
                                        TimeoutException

Retrieves the first message found from queue or other channel, that matches the specified messageSelector.

Parameters:

messageSelector - search criteria for messages. Not that the format of the selector changes per listener, for example a JMSListener's messageSelector follows the JMS specification.

threadContext - context in which the method is called

Throws:

ListenerException

TimeoutException