Class InputOutputPipeProcessor

java.lang.Object

org.frankframework.processors.AbstractPipeProcessor

org.frankframework.processors.InputOutputPipeProcessor

All Implemented Interfaces:

PipeProcessor

public class InputOutputPipeProcessor
extends AbstractPipeProcessor

The InputOutputPipeProcessor class is a subclass of PipeProcessorBase and is responsible for processing pipes in a pipeline. It handles input and output manipulation, including replacing input with session values, replacing input with fixed values, replacing empty input with a fixed value, restoring moved elements from a compacted result, compacting a received message, storing a result in a session key, preserving input, and writing to a secure log.

Author:

Jaco de Groot

Constructor Summary

Constructors

Constructor	Description
InputOutputPipeProcessor()

Method Summary

Modifier and Type	Method	Description
@NonNull PipeRunResult	processPipe(@NonNull PipeLine pipeLine, @NonNull IPipe pipe, @NonNull Message message, @NonNull PipeLineSession pipeLineSession)
protected @NonNull PipeRunResult	processPipe(@NonNull PipeLine pipeLine, @NonNull IPipe pipe, @NonNull Message inputMessage, @NonNull PipeLineSession pipeLineSession, @NonNull ThrowingFunction<Message, PipeRunResult, PipeRunException> chain)	Processes the pipe in the pipeline.

Methods inherited from class AbstractPipeProcessor

validate

Methods inherited from class Object

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

Constructor Details

InputOutputPipeProcessor

public InputOutputPipeProcessor()

Method Details

processPipe

protected @NonNull PipeRunResult processPipe(@NonNull PipeLine pipeLine,
 @NonNull IPipe pipe,
 @NonNull Message inputMessage,
 @NonNull PipeLineSession pipeLineSession,
 @NonNull ThrowingFunction<Message, PipeRunResult, PipeRunException> chain)
                                      throws PipeRunException

Processes the pipe in the pipeline. This method is called by the Pipeline to process the given pipe. It performs various operations on the message and modifies it as required.

Specified by:

processPipe in class AbstractPipeProcessor

Parameters:

pipeLine - The PipeLine to which the pipe belongs.

pipe - The pipe to be processed.

pipeLineSession - The session of the pipeline execution.

chain - The chain of functions to be executed.

message - The message to be processed.

Returns:

The result of processing the pipe.

Throws:

PipeRunException - if there is an error during processing.

processPipe

public @NonNull PipeRunResult processPipe(@NonNull PipeLine pipeLine,
 @NonNull IPipe pipe,
 @NonNull Message message,
 @NonNull PipeLineSession pipeLineSession)
                                   throws PipeRunException

Specified by:

processPipe in interface PipeProcessor

Overrides:

processPipe in class AbstractPipeProcessor

Throws:

PipeRunException