Package org.frankframework.processors

Class LimitingParallelExecutionPipeProcessor

java.lang.Object

org.frankframework.processors.PipeProcessorBase

org.frankframework.processors.LimitingParallelExecutionPipeProcessor

All Implemented Interfaces:

PipeProcessor

public class LimitingParallelExecutionPipeProcessor
extends PipeProcessorBase

Processor that limits the number of parallel pipe threads.

Author:

Jaco de Groot

Field Summary

Fields inherited from class org.frankframework.processors.PipeProcessorBase

log

Constructor Summary

Constructors

Constructor	Description
LimitingParallelExecutionPipeProcessor()

Method Summary

Modifier and Type	Method	Description
PipeRunResult	processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected 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 org.frankframework.processors.PipeProcessorBase

setPipeProcessor

Methods inherited from class java.lang.Object

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

Constructor Details

LimitingParallelExecutionPipeProcessor

public LimitingParallelExecutionPipeProcessor()

Method Details

processPipe

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

Specified by:

processPipe in class PipeProcessorBase

Throws:

PipeRunException

processPipe

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

Specified by:

processPipe in interface PipeProcessor

Overrides:

processPipe in class PipeProcessorBase

Throws:

PipeRunException

validate

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

Specified by:

validate in interface PipeProcessor

Overrides:

validate in class PipeProcessorBase

Throws:

PipeRunException