protected PipeRunResult |
LockerPipeProcessor.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
protected PipeRunResult |
MonitoringPipeProcessor.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
protected PipeRunResult |
ExceptionHandlingPipeProcessor.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
protected PipeRunResult |
TransactionAttributePipeProcessor.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
protected PipeRunResult |
CheckSemaphorePipeProcessor.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
protected PipeRunResult |
CheckMessageSizePipeProcessor.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
protected abstract PipeRunResult |
PipeProcessorBase.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |
protected PipeRunResult |
InputOutputPipeProcessor.processPipe(PipeLine pipeLine,
IPipe pipe,
Message message,
PipeLineSession pipeLineSession,
ThrowingFunction<Message,PipeRunResult,PipeRunException> chain) |