nl.nn.adapterframework.processors

Class CheckSemaphorePipeProcessor

java.lang.Object

nl.nn.adapterframework.processors.PipeProcessorBase

nl.nn.adapterframework.processors.CheckSemaphorePipeProcessor

All Implemented Interfaces:

PipeProcessor

public class CheckSemaphorePipeProcessor
extends PipeProcessorBase

Author:

Jaco de Groot

Field Summary

Fields inherited from class nl.nn.adapterframework.processors.PipeProcessorBase

log

Constructor Summary

Constructors

Constructor and Description
CheckSemaphorePipeProcessor()

Method Summary

Modifier and Type	Method and 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 nl.nn.adapterframework.processors.PipeProcessorBase

setPipeProcessor

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckSemaphorePipeProcessor

public CheckSemaphorePipeProcessor()

Method Detail

processPipe

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

Specified by:

processPipe in class PipeProcessorBase

Throws:

PipeRunException

processPipe

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

Specified by:

processPipe in interface PipeProcessor

Overrides:

processPipe in class PipeProcessorBase

Throws:

PipeRunException

validate

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

Specified by:

validate in interface PipeProcessor

Overrides:

validate in class PipeProcessorBase

Throws:

PipeRunException