Interface PipeLineProcessor

All Known Implementing Classes:

AbstractPipeLineProcessor, CachePipeLineProcessor, CorePipeLineProcessor, InputOutputPipeLineProcessor, LimitingParallelExecutionPipeLineProcessor, LockerPipeLineProcessor, TransactionAttributePipeLineProcessor

public interface PipeLineProcessor

Author:

Jaco de Groot

Method Summary

Modifier and Type	Method	Description
@NonNull PipeLineResult	processPipeLine(@Nullable Receiver<?> receiver, @NonNull PipeLine pipeLine, @NonNull String messageId, @NonNull Message message, @NonNull PipeLineSession pipeLineSession, @NonNull String firstPipe)

Method Details

processPipeLine

@NonNull PipeLineResult processPipeLine(@Nullable Receiver<?> receiver,
 @NonNull PipeLine pipeLine,
 @NonNull String messageId,
 @NonNull Message message,
 @NonNull PipeLineSession pipeLineSession,
 @NonNull String firstPipe)
                                 throws PipeRunException

Throws:

PipeRunException