org.mule.transport

Class TransactedPollingMessageReceiver.MessageProcessorWorker

java.lang.Object

org.mule.transport.TransactedPollingMessageReceiver.MessageProcessorWorker

All Implemented Interfaces:

Runnable, javax.resource.spi.work.Work, TransactionCallback

Enclosing class:

TransactedPollingMessageReceiver

protected class TransactedPollingMessageReceiver.MessageProcessorWorker
extends Object
implements javax.resource.spi.work.Work, TransactionCallback

Constructor Summary

Constructors

Constructor and Description
TransactedPollingMessageReceiver.MessageProcessorWorker(TransactionTemplate tt, CountDownLatch latch, Object message)

Method Summary

Methods

Modifier and Type	Method and Description
Object	doInTransaction()
void	release()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactedPollingMessageReceiver.MessageProcessorWorker

public TransactedPollingMessageReceiver.MessageProcessorWorker(TransactionTemplate tt,
                                                       CountDownLatch latch,
                                                       Object message)

Method Detail

release

public void release()

Specified by:

release in interface javax.resource.spi.work.Work

run

public void run()

Specified by:

run in interface Runnable

doInTransaction

public Object doInTransaction()
                       throws Exception

Specified by:

doInTransaction in interface TransactionCallback

Throws:

Exception