void |
ProtonSession.addConsumer(org.apache.qpid.proton.engine.Sender sender) |
void |
ProtonSession.addProducer(org.apache.qpid.proton.engine.Receiver receiver) |
void |
ProtonConsumer.close() |
void |
TransactionHandler.close() |
void |
ProtonProducer.close() |
void |
ProtonDeliveryHandler.close() |
ProtonSession |
ProtonProtocolManager.createSession(ProtonRemotingConnection protonConnection,
org.apache.qpid.proton.engine.impl.TransportImpl protonTransport) |
void |
ProtonConsumer.init() |
void |
ProtonProducer.init() |
void |
ProtonConsumer.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
TransactionHandler.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
ProtonProducer.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
ProtonDeliveryHandler.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
ProtonSession.removeConsumer(long consumerID) |
void |
ProtonConsumer.start() |