Package org.frankframework.processors

Class InputOutputPipeProcessor

java.lang.Object

org.frankframework.processors.PipeProcessorBase

org.frankframework.processors.InputOutputPipeProcessor

All Implemented Interfaces:

PipeProcessor

public class InputOutputPipeProcessor
extends PipeProcessorBase

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

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.logging.log4j.Logger	secLog

Fields inherited from class org.frankframework.processors.PipeProcessorBase

log

Constructor Summary

Constructors

Constructor	Description
InputOutputPipeProcessor()

Method Summary

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

Methods inherited from class org.frankframework.processors.PipeProcessorBase

setPipeProcessor, validate

Methods inherited from class java.lang.Object

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

Field Details

secLog

protected org.apache.logging.log4j.Logger secLog

Constructor Details

InputOutputPipeProcessor

public InputOutputPipeProcessor()

Method Details

processPipe

protected PipeRunResult processPipe(@Nonnull
 PipeLine pipeLine,
 @Nonnull
 IPipe pipe,
 @Nullable
 Message message,
 @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 PipeProcessorBase

Parameters:

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.

Returns:

The result of processing the pipe.

Throws:

PipeRunException - if there is an error during processing.

processPipe

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

Specified by:

processPipe in interface PipeProcessor

Overrides:

processPipe in class PipeProcessorBase

Throws:

PipeRunException