public class CoreListenerProcessor<M> extends Object implements ListenerProcessor<M>
Constructor and Description |
---|
CoreListenerProcessor() |
Modifier and Type | Method and Description |
---|---|
protected String |
getLogPrefix(ICorrelatedPullingListener<M> listener,
PipeLineSession session) |
Message |
getMessage(ICorrelatedPullingListener<M> listener,
String correlationID,
PipeLineSession pipeLineSession) |
public Message getMessage(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession) throws ListenerException, TimeoutException
getMessage
in interface ListenerProcessor<M>
ListenerException
TimeoutException
protected String getLogPrefix(ICorrelatedPullingListener<M> listener, PipeLineSession session)
Copyright © 2023 Frank!Framework. All rights reserved.