Package org.frankframework.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	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 org.frankframework.core.IConfigurationAware

getApplicationContext, getName

Methods inherited from interface org.frankframework.core.IListener

afterMessageProcessed, close, configure, extractMessage, open

Methods inherited from interface org.frankframework.core.INamedObject

getName, setName

Methods inherited from interface org.frankframework.core.IPullingListener

closeThread, getRawMessage, openThread

Methods inherited from interface org.frankframework.core.IScopeProvider

getConfigurationClassLoader

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