nl.nn.adapterframework.processors

Class CoreListenerProcessor<M>

java.lang.Object

nl.nn.adapterframework.processors.CoreListenerProcessor<M>

All Implemented Interfaces:

ListenerProcessor<M>

public class CoreListenerProcessor<M>
extends Object
implements ListenerProcessor<M>

Author:

Jaco de Groot

Constructor Summary

Constructors

Constructor and Description
CoreListenerProcessor()

Method Summary

Modifier and Type	Method and Description
protected String	getLogPrefix(ICorrelatedPullingListener<M> listener, PipeLineSession session)
Message	getMessage(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CoreListenerProcessor

public CoreListenerProcessor()

Method Detail

getMessage

public Message getMessage(ICorrelatedPullingListener<M> listener,
                          String correlationID,
                          PipeLineSession pipeLineSession)
                   throws ListenerException,
                          TimeoutException

Specified by:

getMessage in interface ListenerProcessor<M>

Throws:

ListenerException

TimeoutException

getLogPrefix

protected String getLogPrefix(ICorrelatedPullingListener<M> listener,
                              PipeLineSession session)