Package org.frankframework.processors

Class TransactionAttributePipeProcessor

java.lang.Object

org.frankframework.processors.AbstractPipeProcessor

org.frankframework.processors.TransactionAttributePipeProcessor

All Implemented Interfaces:

PipeProcessor

public class TransactionAttributePipeProcessor
extends AbstractPipeProcessor

Author:

Jaco de Groot

Field Summary

Fields inherited from class org.frankframework.processors.AbstractPipeProcessor

log

Constructor Summary

Constructors

Constructor	Description
TransactionAttributePipeProcessor()

Method Summary

Modifier and Type	Method	Description
org.springframework.transaction.PlatformTransactionManager	getTxManager()
protected PipeRunResult	processPipe(PipeLine pipeline, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
void	setTxManager(org.springframework.transaction.PlatformTransactionManager txManager)

Methods inherited from class org.frankframework.processors.AbstractPipeProcessor

processPipe, setPipeProcessor, validate

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionAttributePipeProcessor

public TransactionAttributePipeProcessor()

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 AbstractPipeProcessor

Throws:

PipeRunException

getTxManager

public org.springframework.transaction.PlatformTransactionManager getTxManager()

setTxManager

public void setTxManager(org.springframework.transaction.PlatformTransactionManager txManager)