Package | Description |
---|---|
org.proton.plug | |
org.proton.plug.context | |
org.proton.plug.context.client | |
org.proton.plug.context.server | |
org.proton.plug.exceptions |
Modifier and Type | Method and Description |
---|---|
AMQPClientSessionContext |
AMQPClientConnectionContext.createClientSession() |
AMQPClientSenderContext |
AMQPClientSessionContext.createDynamicSender(boolean preSettled) |
AMQPClientReceiverContext |
AMQPClientSessionContext.createReceiver(String address) |
AMQPClientReceiverContext |
AMQPClientSessionContext.createReceiver(String name,
String address) |
AMQPClientSenderContext |
AMQPClientSessionContext.createSender(String address,
boolean preSettled) |
void |
AMQPSessionContext.removeSender(org.apache.qpid.proton.engine.Sender sender) |
Modifier and Type | Method and Description |
---|---|
void |
ProtonTransactionHandler.close(boolean linkRemoteClose) |
void |
AbstractProtonReceiverContext.close(boolean remoteLinkClose) |
void |
ProtonDeliveryHandler.close(boolean remoteLinkClose) |
void |
AbstractProtonContextSender.close(boolean linkRemoteClose) |
void |
ProtonTransactionHandler.close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
void |
AbstractProtonReceiverContext.close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
void |
ProtonDeliveryHandler.close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
void |
AbstractProtonContextSender.close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
protected AbstractProtonSessionContext |
AbstractConnectionContext.getSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
protected abstract AbstractProtonSessionContext |
AbstractConnectionContext.newSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
void |
ProtonTransactionHandler.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
ProtonDeliveryHandler.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
abstract void |
AbstractProtonContextSender.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
AbstractProtonSessionContext.removeSender(org.apache.qpid.proton.engine.Sender sender) |
void |
AbstractProtonContextSender.start() |
void |
ProtonInitializable.waitWithTimeout(FutureRunnable latch) |
Modifier and Type | Method and Description |
---|---|
AMQPClientSessionContext |
ProtonClientConnectionContext.createClientSession() |
AMQPClientSenderContext |
ProtonClientSessionContext.createDynamicSender(boolean preSettled) |
AMQPClientReceiverContext |
ProtonClientSessionContext.createReceiver(String address) |
AMQPClientReceiverContext |
ProtonClientSessionContext.createReceiver(String name,
String address) |
AMQPClientSenderContext |
ProtonClientSessionContext.createSender(String address,
boolean preSettled) |
protected AbstractProtonSessionContext |
ProtonClientConnectionContext.newSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
void |
ProtonClientContext.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
ProtonClientReceiverContext.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
Modifier and Type | Method and Description |
---|---|
void |
ProtonServerSenderContext.close(boolean remoteLinkClose) |
void |
ProtonServerSenderContext.close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
protected AbstractProtonSessionContext |
ProtonServerConnectionContext.newSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
void |
ProtonServerReceiverContext.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
ProtonServerSenderContext.onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
ProtonServerSessionContext.removeSender(org.apache.qpid.proton.engine.Sender sender) |
void |
ProtonServerSenderContext.start() |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQAMQPIllegalStateException |
class |
ActiveMQAMQPInternalErrorException |
class |
ActiveMQAMQPInvalidFieldException |
class |
ActiveMQAMQPNotFoundException |
class |
ActiveMQAMQPNotImplementedException |
class |
ActiveMQAMQPResourceLimitExceededException |
class |
ActiveMQAMQPTimeoutException |
Copyright © 2016 The Apache Software Foundation. All rights reserved.