public class InputOutputPipeProcessor extends PipeProcessorBase
Modifier and Type | Field and Description |
---|---|
protected org.apache.logging.log4j.Logger |
secLog |
log
Constructor and Description |
---|
InputOutputPipeProcessor() |
Modifier and Type | Method and Description |
---|---|
PipeRunResult |
processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession) |
protected PipeRunResult |
processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
Processes the pipe in the pipeline.
|
setPipeProcessor, validate
protected PipeRunResult processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) throws PipeRunException
processPipe
in class PipeProcessorBase
pipeLine
- The PipeLine to which the pipe belongs.pipe
- The pipe to be processed.message
- The message to be processed.pipeLineSession
- The session of the pipeline execution.chain
- The chain of functions to be executed.PipeRunException
- if there is an error during processing.public PipeRunResult processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession) throws PipeRunException
processPipe
in interface PipeProcessor
processPipe
in class PipeProcessorBase
PipeRunException
Copyright © 2023 Frank!Framework. All rights reserved.