nl.nn.adapterframework.processors

Class PipeProcessorBase

java.lang.Object

nl.nn.adapterframework.processors.PipeProcessorBase

All Implemented Interfaces:

PipeProcessor

Direct Known Subclasses:

CheckMessageSizePipeProcessor, CheckSemaphorePipeProcessor, ExceptionHandlingPipeProcessor, InputOutputPipeProcessor, LockerPipeProcessor, MonitoringPipeProcessor, TransactionAttributePipeProcessor

public abstract class PipeProcessorBase
extends Object
implements PipeProcessor

Baseclass for PipeProcessors.

Since:

4.11

Author:

Gerrit van Brakel

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
PipeProcessorBase()

Method Summary

Modifier and Type	Method and Description
PipeRunResult	processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected abstract PipeRunResult	processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
void	setPipeProcessor(PipeProcessor pipeProcessor)
PipeRunResult	validate(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.apache.logging.log4j.Logger log

Constructor Detail

PipeProcessorBase

public PipeProcessorBase()

Method Detail

setPipeProcessor

public void setPipeProcessor(PipeProcessor pipeProcessor)

processPipe

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

Throws:

PipeRunException

processPipe

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

Specified by:

processPipe in interface PipeProcessor

Throws:

PipeRunException

validate

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

Specified by:

validate in interface PipeProcessor

Throws:

PipeRunException