nl.nn.adapterframework.processors

Class InputOutputPipeProcessor

java.lang.Object

nl.nn.adapterframework.processors.PipeProcessorBase

nl.nn.adapterframework.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 and Description
protected org.apache.logging.log4j.Logger	secLog

Fields inherited from class nl.nn.adapterframework.processors.PipeProcessorBase

log

Constructor Summary

Constructors

Constructor and Description
InputOutputPipeProcessor()

Method Summary

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.

Methods inherited from class nl.nn.adapterframework.processors.PipeProcessorBase

setPipeProcessor, validate

Methods inherited from class java.lang.Object

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

Field Detail

secLog

protected org.apache.logging.log4j.Logger secLog

Constructor Detail

InputOutputPipeProcessor

public InputOutputPipeProcessor()

Method Detail

processPipe

protected PipeRunResult processPipe(PipeLine pipeLine,
                                    IPipe pipe,
                                    Message message,
                                    PipeLineSession pipeLineSession,
                                    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(PipeLine pipeLine,
                                 IPipe pipe,
                                 Message message,
                                 PipeLineSession pipeLineSession)
                          throws PipeRunException

Specified by:

processPipe in interface PipeProcessor

Overrides:

processPipe in class PipeProcessorBase

Throws:

PipeRunException