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) |
Modifier and Type | Method and Description |
---|---|
void |
checkState() |
void |
close() |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
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 © 2015 JBoss, a division of Red Hat. All rights reserved.