public class TransactionalInterceptingMessageProcessor extends AbstractInterceptingMessageProcessor implements Lifecycle, MuleContextAware
MessageProcessor
with a transaction. If
the TransactionConfig
is null then no transaction is used and the next
MessageProcessor
is invoked directly.Modifier and Type | Field and Description |
---|---|
protected MessagingExceptionHandler |
exceptionListener |
protected MuleTransactionConfig |
transactionConfig |
logger, muleContext, next, notificationHandler
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
TransactionalInterceptingMessageProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
dispose()
A lifecycle method where implementor should free up any resources.
|
void |
initialise()
Method used to perform any initialisation work.
|
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
void |
setExceptionListener(MessagingExceptionHandler exceptionListener) |
void |
setTransactionConfig(MuleTransactionConfig transactionConfig) |
void |
start() |
void |
stop() |
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setMuleContext
setListener
protected MessagingExceptionHandler exceptionListener
protected MuleTransactionConfig transactionConfig
public TransactionalInterceptingMessageProcessor()
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processedMuleException
public void setExceptionListener(MessagingExceptionHandler exceptionListener)
public void setTransactionConfig(MuleTransactionConfig transactionConfig)
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered frompublic void dispose()
Disposable
dispose
in interface Disposable
public void start() throws MuleException
start
in interface Startable
MuleException
public void stop() throws MuleException
stop
in interface Stoppable
MuleException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.