public class TransactionHandler extends Object implements ProtonDeliveryHandler
Constructor and Description |
---|
TransactionHandler(ProtonRemotingConnection connection,
org.apache.qpid.proton.amqp.transaction.Coordinator coordinator,
ProtonProtocolManager protonProtocolManager,
ProtonSession protonSession) |
public TransactionHandler(ProtonRemotingConnection connection, org.apache.qpid.proton.amqp.transaction.Coordinator coordinator, ProtonProtocolManager protonProtocolManager, ProtonSession protonSession)
public void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws HornetQAMQPException
onMessage
in interface ProtonDeliveryHandler
HornetQAMQPException
public void checkState()
checkState
in interface ProtonDeliveryHandler
public void close() throws HornetQAMQPException
close
in interface ProtonDeliveryHandler
HornetQAMQPException
Copyright © 2013 JBoss, a division of Red Hat. All rights reserved.