public class ProtonTransactionHandler extends Object implements ProtonDeliveryHandler
Constructor and Description |
---|
ProtonTransactionHandler(AMQPSessionCallback sessionSPI) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean linkRemoteClose) |
void |
close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
void |
onFlow(int credits,
boolean drain) |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
public ProtonTransactionHandler(AMQPSessionCallback sessionSPI)
public void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws ActiveMQAMQPException
onMessage
in interface ProtonDeliveryHandler
ActiveMQAMQPException
public void onFlow(int credits, boolean drain)
onFlow
in interface ProtonDeliveryHandler
public void close(boolean linkRemoteClose) throws ActiveMQAMQPException
close
in interface ProtonDeliveryHandler
ActiveMQAMQPException
public void close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) throws ActiveMQAMQPException
close
in interface ProtonDeliveryHandler
ActiveMQAMQPException
Copyright © 2016 The Apache Software Foundation. All rights reserved.