nl.nn.adapterframework.core

Interface ICorrelatedPullingListener<M>

Type Parameters:

M - the raw message type

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 ICorrelatedPullingListener<M>
extends IPullingListener<M>

Additional behaviour for pulling listeners that are able to listen to a specific message, specified by a correlation ID.

Since:

4.0

Author:

Gerrit van Brakel

Method Summary

Modifier and Type	Method and Description
RawMessageWrapper<M>	getRawMessage(String correlationId, Map<String,Object> threadContext) Retrieves messages from queue or other channel, but retrieves only messages with the specified correlationId.

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

getRawMessage

RawMessageWrapper<M> getRawMessage(String correlationId,
                                   Map<String,Object> threadContext)
                            throws ListenerException,
                                   TimeoutException

Retrieves messages from queue or other channel, but retrieves only messages with the specified correlationId.

Throws:

ListenerException

TimeoutException