org.hornetq.core.protocol.proton

Class TransactionHandler

java.lang.Object

org.hornetq.core.protocol.proton.TransactionHandler

All Implemented Interfaces:

ProtonDeliveryHandler

public class TransactionHandler
extends Object
implements ProtonDeliveryHandler

handles an amqp Coordinator to deal with transaction boundaries etc

Constructor Summary

Constructors

Constructor and Description
TransactionHandler(ProtonRemotingConnection connection, org.apache.qpid.proton.amqp.transaction.Coordinator coordinator, ProtonProtocolManager protonProtocolManager, ProtonSession protonSession)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkState()
void	close()
void	onMessage(org.apache.qpid.proton.engine.Delivery delivery)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionHandler

public TransactionHandler(ProtonRemotingConnection connection,
                  org.apache.qpid.proton.amqp.transaction.Coordinator coordinator,
                  ProtonProtocolManager protonProtocolManager,
                  ProtonSession protonSession)

Method Detail

onMessage

public void onMessage(org.apache.qpid.proton.engine.Delivery delivery)
               throws HornetQAMQPException

Specified by:

onMessage in interface ProtonDeliveryHandler

Throws:

HornetQAMQPException

checkState

public void checkState()

Specified by:

checkState in interface ProtonDeliveryHandler

close

public void close()
           throws HornetQAMQPException

Specified by:

close in interface ProtonDeliveryHandler

Throws:

HornetQAMQPException