Package org.frankframework.processors

Class CoreListenerProcessor<M>

java.lang.Object

org.frankframework.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	Description
CoreListenerProcessor()

Method Summary

Modifier and Type	Method	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 Details

CoreListenerProcessor

public CoreListenerProcessor()

Method Details

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)