Package org.frankframework.processors

Class LimitingParallelExecutionPipeLineProcessor

java.lang.Object

org.frankframework.processors.PipeLineProcessorBase

org.frankframework.processors.LimitingParallelExecutionPipeLineProcessor

All Implemented Interfaces:

PipeLineProcessor

public class LimitingParallelExecutionPipeLineProcessor
extends PipeLineProcessorBase

Processor that limits the number of parallel pipeline threads.

Author:

Gerrit van Brakel

Field Summary

Fields inherited from class org.frankframework.processors.PipeLineProcessorBase

log, pipeLineProcessor

Constructor Summary

Constructors

Constructor	Description
LimitingParallelExecutionPipeLineProcessor()

Method Summary

Modifier and Type	Method	Description
PipeLineResult	processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)

Methods inherited from class org.frankframework.processors.PipeLineProcessorBase

setPipeLineProcessor

Methods inherited from class java.lang.Object

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

Constructor Details

LimitingParallelExecutionPipeLineProcessor

public LimitingParallelExecutionPipeLineProcessor()

Method Details

processPipeLine

public PipeLineResult processPipeLine(PipeLine pipeLine,
 String messageId,
 Message message,
 PipeLineSession pipeLineSession,
 String firstPipe)
                               throws PipeRunException

Throws:

PipeRunException