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, 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 org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasName

getName

Methods inherited from interface org.frankframework.core.IConfigurable

configure

Methods inherited from interface org.frankframework.core.IListener

afterMessageProcessed, extractMessage, start, stop

Methods inherited from interface org.frankframework.core.IPullingListener

closeThread, getRawMessage, openThread

Methods inherited from interface org.frankframework.core.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