Package | Description |
---|---|
org.apache.qpid.jms.provider.amqp | |
org.apache.qpid.jms.provider.amqp.builders |
Modifier and Type | Method and Description |
---|---|
AmqpProvider |
AmqpResourceParent.getProvider() |
AmqpProvider |
AmqpTransactionContext.getProvider() |
AmqpProvider |
AmqpConnection.getProvider() |
AmqpProvider |
AmqpSession.getProvider() |
AmqpProvider |
AmqpProvider.getProvider() |
Modifier and Type | Method and Description |
---|---|
void |
AmqpEventSink.processDeliveryUpdates(AmqpProvider provider)
Called when the Proton Engine signals an Delivery related event has been triggered
for the given endpoint.
|
void |
AmqpFixedProducer.processDeliveryUpdates(AmqpProvider provider) |
void |
AmqpConsumer.processDeliveryUpdates(AmqpProvider provider) |
void |
AmqpTransactionCoordinator.processDeliveryUpdates(AmqpProvider provider) |
void |
AmqpAbstractResource.processDeliveryUpdates(AmqpProvider provider) |
void |
AmqpEventSink.processFlowUpdates(AmqpProvider provider)
Called when the Proton Engine signals an Flow related event has been triggered
for the given endpoint.
|
void |
AmqpFixedProducer.processFlowUpdates(AmqpProvider provider) |
void |
AmqpConsumer.processFlowUpdates(AmqpProvider provider) |
void |
AmqpAbstractResource.processFlowUpdates(AmqpProvider provider) |
void |
AmqpEventSink.processRemoteClose(AmqpProvider provider)
Event handler for remote peer close of this resource.
|
void |
AmqpAbstractResource.processRemoteClose(AmqpProvider provider) |
void |
AmqpEventSink.processRemoteDetach(AmqpProvider provider)
Event handler for remote peer detach of this resource.
|
void |
AmqpAbstractResource.processRemoteDetach(AmqpProvider provider) |
void |
AmqpEventSink.processRemoteOpen(AmqpProvider provider)
Event handler for remote peer open of this resource.
|
void |
AmqpAbstractResource.processRemoteOpen(AmqpProvider provider) |
void |
AmqpFixedProducer.remotelyClosed(AmqpProvider provider) |
void |
AmqpTransactionCoordinator.remotelyClosed(AmqpProvider provider) |
void |
AmqpAbstractResource.remotelyClosed(AmqpProvider provider) |
Constructor and Description |
---|
AmqpConnection(AmqpProvider provider,
JmsConnectionInfo info,
org.apache.qpid.proton.engine.Connection protonConnection) |
Modifier and Type | Method and Description |
---|---|
protected AmqpConnection |
AmqpConnectionBuilder.createResource(AmqpProvider parent,
JmsConnectionInfo resourceInfo,
org.apache.qpid.proton.engine.Connection endpoint) |
protected void |
AmqpResourceBuilder.handleClosed(AmqpProvider provider,
Throwable cause) |
protected void |
AmqpResourceBuilder.handleOpened(AmqpProvider provider) |
void |
AmqpResourceBuilder.processDeliveryUpdates(AmqpProvider provider) |
void |
AmqpResourceBuilder.processFlowUpdates(AmqpProvider provider) |
void |
AmqpResourceBuilder.processRemoteClose(AmqpProvider provider) |
void |
AmqpResourceBuilder.processRemoteDetach(AmqpProvider provider) |
void |
AmqpResourceBuilder.processRemoteOpen(AmqpProvider provider) |
Constructor and Description |
---|
AmqpConnectionBuilder(AmqpProvider parent,
JmsConnectionInfo resourceInfo) |
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.