Interface ICorrelatedPullingListener<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>, IPullingListener<M>, IScopeProvider, NameAware

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	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 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 IPullingListener

closeThread, getRawMessage, openThread

Methods inherited from interface NameAware

setName

Method Details

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