Package org.frankframework.processors

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
PipeRunResult	processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected abstract PipeRunResult	processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
PipeRunResult	validate(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractPipeProcessor

public AbstractPipeProcessor()

Method Details

processPipe

protected abstract 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 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 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