Class AbstractPipeProcessor

java.lang.Object

org.frankframework.processors.AbstractPipeProcessor

All Implemented Interfaces:

PipeProcessor

Direct Known Subclasses:

CheckMessageSizePipeProcessor, ExceptionHandlingPipeProcessor, InputOutputPipeProcessor, LimitingParallelExecutionPipeProcessor, LockerPipeProcessor, LogPipeProcessor, MonitoringPipeProcessor, TrackPreviousPipeInMetadataProcessor, TransactionAttributePipeProcessor

public abstract class AbstractPipeProcessor
extends Object
implements PipeProcessor

Baseclass for PipeProcessors.

Since:

4.11

Author:

Gerrit van Brakel

Constructor Summary

Constructors

Constructor	Description
AbstractPipeProcessor()

Method Summary

Modifier and Type	Method	Description
@NonNull PipeRunResult	processPipe(@NonNull PipeLine pipeLine, @NonNull IPipe pipe, @NonNull Message message, @NonNull PipeLineSession pipeLineSession)
protected abstract @NonNull PipeRunResult	processPipe(@NonNull PipeLine pipeLine, @NonNull IPipe pipe, @NonNull Message message, @NonNull PipeLineSession pipeLineSession, @NonNull ThrowingFunction<Message, PipeRunResult, PipeRunException> chain)
@NonNull PipeRunResult	validate(@NonNull PipeLine pipeLine, @NonNull IValidator validator, @NonNull Message message, @NonNull PipeLineSession pipeLineSession, String messageRoot)

Methods inherited from class Object

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

Constructor Details

AbstractPipeProcessor

public AbstractPipeProcessor()

Method Details

processPipe

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

Throws:

PipeRunException

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

Throws:

PipeRunException

validate

public @NonNull PipeRunResult validate(@NonNull PipeLine pipeLine,
 @NonNull IValidator validator,
 @NonNull Message message,
 @NonNull PipeLineSession pipeLineSession,
 String messageRoot)
                                throws PipeRunException

Specified by:

validate in interface PipeProcessor

Throws:

PipeRunException