Class LimitingParallelExecutionPipeProcessor

java.lang.Object

org.frankframework.processors.AbstractPipeProcessor

org.frankframework.processors.LimitingParallelExecutionPipeProcessor

All Implemented Interfaces:

PipeProcessor

public class LimitingParallelExecutionPipeProcessor
extends AbstractPipeProcessor

Processor that limits the number of parallel pipe threads.

Constructor Summary

Constructors

Constructor	Description
LimitingParallelExecutionPipeProcessor()

Method Summary

Modifier and Type	Method	Description
@NonNull PipeRunResult	processPipe(@NonNull PipeLine pipeLine, @NonNull IPipe pipe, @NonNull Message message, @NonNull PipeLineSession pipeLineSession)
protected @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

LimitingParallelExecutionPipeProcessor

public LimitingParallelExecutionPipeProcessor()

Method Details

processPipe

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

Specified by:

processPipe in class AbstractPipeProcessor

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

Overrides:

processPipe in class AbstractPipeProcessor

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

Overrides:

validate in class AbstractPipeProcessor

Throws:

PipeRunException