public abstract class PipeProcessorBase extends Object implements PipeProcessor
Modifier and Type | Field and Description |
---|---|
protected org.apache.logging.log4j.Logger |
log |
Constructor and Description |
---|
PipeProcessorBase() |
Modifier and Type | Method and Description |
---|---|
PipeRunResult |
processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession) |
protected abstract PipeRunResult |
processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
void |
setPipeProcessor(PipeProcessor pipeProcessor) |
PipeRunResult |
validate(PipeLine pipeLine,
IValidator validator,
Message message,
PipeLineSession pipeLineSession,
String messageRoot) |
public void setPipeProcessor(PipeProcessor pipeProcessor)
protected abstract PipeRunResult processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) throws PipeRunException
PipeRunException
public PipeRunResult processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession) throws PipeRunException
processPipe
in interface PipeProcessor
PipeRunException
public PipeRunResult validate(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot) throws PipeRunException
validate
in interface PipeProcessor
PipeRunException
Copyright © 2023 Frank!Framework. All rights reserved.