Interface PipeProcessor

All Known Implementing Classes:

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

public interface PipeProcessor

Author:

Jaco de Groot

Method Summary

Modifier and Type	Method	Description
@NonNull PipeRunResult	processPipe(@NonNull PipeLine pipeLine, @NonNull IPipe pipe, @NonNull Message message, @NonNull PipeLineSession pipeLineSession)
@NonNull PipeRunResult	validate(@NonNull PipeLine pipeLine, @NonNull IValidator validator, @NonNull Message message, @NonNull PipeLineSession pipeLineSession, String messageRoot)

Method Details

processPipe

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

Throws:

PipeRunException

validate

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

Throws:

PipeRunException