Package | Description |
---|---|
org.apache.qpid.jms.provider | |
org.apache.qpid.jms.provider.amqp | |
org.apache.qpid.jms.provider.amqp.builders | |
org.apache.qpid.jms.provider.failover |
Modifier and Type | Class and Description |
---|---|
class |
NoOpAsyncResult
Simple NoOp implementation used when the result of the operation does not matter.
|
class |
ProviderFuture
Asynchronous Provider Future class.
|
class |
WrappedAsyncResult
Base class used to wrap one AsyncResult with another.
|
Modifier and Type | Method and Description |
---|---|
AsyncResult |
WrappedAsyncResult.getWrappedRequest() |
Modifier and Type | Method and Description |
---|---|
void |
Provider.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request)
Called to acknowledge a JmsMessage has been delivered, consumed, re-delivered...etc.
|
void |
ProviderWrapper.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
Provider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request)
Called to acknowledge all messages that have been delivered in a given session.
|
void |
ProviderWrapper.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
Provider.commit(JmsTransactionInfo transactionInfo,
AsyncResult request)
Called to commit an open transaction.
|
void |
ProviderWrapper.commit(JmsTransactionInfo transactionInfo,
AsyncResult request) |
void |
Provider.create(JmsResource resource,
AsyncResult request)
Create the Provider version of the given JmsResource.
|
void |
ProviderWrapper.create(JmsResource resource,
AsyncResult request) |
void |
Provider.destroy(JmsResource resource,
AsyncResult request)
Instruct the Provider to dispose of a given JmsResource.
|
void |
ProviderWrapper.destroy(JmsResource resourceId,
AsyncResult request) |
void |
Provider.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request)
Request a remote peer send a Message to this client.
|
void |
ProviderWrapper.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request) |
void |
Provider.recover(JmsSessionId sessionId,
AsyncResult request)
Called to recover all unacknowledged messages for a Session in client Ack mode.
|
void |
ProviderWrapper.recover(JmsSessionId sessionId,
AsyncResult request) |
void |
Provider.rollback(JmsTransactionInfo transactionInfo,
AsyncResult request)
Called to roll back an open transaction.
|
void |
ProviderWrapper.rollback(JmsTransactionInfo transactionInfo,
AsyncResult request) |
void |
Provider.send(JmsOutboundMessageDispatch envelope,
AsyncResult request)
Sends the JmsMessage contained in the outbound dispatch envelope.
|
void |
ProviderWrapper.send(JmsOutboundMessageDispatch envelope,
AsyncResult request) |
void |
Provider.start(JmsResource resource,
AsyncResult request)
Starts the Provider version of the given JmsResource.
|
void |
ProviderWrapper.start(JmsResource resource,
AsyncResult request) |
void |
Provider.stop(JmsResource resource,
AsyncResult request)
Stops (pauses) the Provider version of the given JmsResource, the resource would then
need to be started again via a call to
start()
For some JMS Resources it is necessary or advantageous to have a stopped state that
can be triggered to stop the resource generating new events or messages. |
void |
ProviderWrapper.stop(JmsResource resource,
AsyncResult request) |
void |
Provider.unsubscribe(String subscription,
AsyncResult request)
Remove a durable topic subscription by name.
|
void |
ProviderWrapper.unsubscribe(String subscription,
AsyncResult request) |
Constructor and Description |
---|
WrappedAsyncResult(AsyncResult wrapped)
Create a new WrappedAsyncResult for the target AsyncResult
|
Modifier and Type | Class and Description |
---|---|
protected static class |
AmqpConsumer.ScheduledStopRequest |
Modifier and Type | Field and Description |
---|---|
protected AsyncResult |
AmqpAbstractResource.closeRequest |
protected AsyncResult |
AmqpConsumer.pullRequest |
protected AsyncResult |
AmqpConsumer.stopRequest |
Modifier and Type | Method and Description |
---|---|
void |
AmqpProvider.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
AmqpProvider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
AmqpTransactionContext.begin(JmsTransactionId txId,
AsyncResult request) |
void |
AmqpSession.begin(JmsTransactionId txId,
AsyncResult request)
Begins a new Transaction using the given Transaction Id as the identifier.
|
void |
AmqpFixedProducer.close(AsyncResult request) |
void |
AmqpAnonymousFallbackProducer.close(AsyncResult request) |
void |
AmqpAbstractResource.close(AsyncResult request) |
void |
AmqpTransactionContext.commit(JmsTransactionInfo transactionInfo,
AsyncResult request) |
void |
AmqpSession.commit(JmsTransactionInfo transactionInfo,
AsyncResult request)
Commit the currently running Transaction.
|
void |
AmqpProvider.commit(JmsTransactionInfo transactionInfo,
AsyncResult request) |
void |
AmqpProvider.create(JmsResource resource,
AsyncResult request) |
void |
AmqpSession.createConsumer(JmsConsumerInfo consumerInfo,
AsyncResult request) |
void |
AmqpSession.createProducer(JmsProducerInfo producerInfo,
AsyncResult request) |
void |
AmqpConnection.createSession(JmsSessionInfo sessionInfo,
AsyncResult request) |
void |
AmqpConnection.createTemporaryDestination(JmsTemporaryDestination destination,
AsyncResult request) |
void |
AmqpTransactionCoordinator.declare(JmsTransactionId txId,
AsyncResult request) |
void |
AmqpProvider.destroy(JmsResource resource,
AsyncResult request) |
void |
AmqpTransactionCoordinator.discharge(JmsTransactionId txId,
AsyncResult request,
boolean commit) |
void |
AmqpProvider.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request) |
void |
AmqpConsumer.pull(long timeout,
AsyncResult request)
Request a remote peer send a Message to this client.
|
protected boolean |
AmqpProvider.pumpToProtonTransport(AsyncResult request) |
void |
AmqpProvider.recover(JmsSessionId sessionId,
AsyncResult request) |
void |
AmqpTransactionContext.rollback(JmsTransactionInfo transactionInfo,
AsyncResult request) |
void |
AmqpSession.rollback(JmsTransactionInfo transactionInfo,
AsyncResult request)
Roll back the currently running Transaction
|
void |
AmqpProvider.rollback(JmsTransactionInfo transactionInfo,
AsyncResult request) |
ScheduledFuture<?> |
AmqpProvider.scheduleRequestTimeout(AsyncResult request,
long timeout,
Exception error)
Allows a resource to request that its parent resource schedule a future
cancellation of a request and return it a
Future instance that
can be used to cancel the scheduled automatic failure of the request. |
boolean |
AmqpFixedProducer.send(JmsOutboundMessageDispatch envelope,
AsyncResult request) |
boolean |
AmqpAnonymousFallbackProducer.send(JmsOutboundMessageDispatch envelope,
AsyncResult request) |
abstract boolean |
AmqpProducer.send(JmsOutboundMessageDispatch envelope,
AsyncResult request)
Sends the given message
|
void |
AmqpProvider.send(JmsOutboundMessageDispatch envelope,
AsyncResult request) |
void |
AmqpConsumer.start(AsyncResult request)
Starts the consumer by setting the link credit to the given prefetch value.
|
void |
AmqpProvider.start(JmsResource resource,
AsyncResult request) |
void |
AmqpConsumer.stop(AsyncResult request)
Stops the consumer, using all link credit and waiting for in-flight messages to arrive.
|
void |
AmqpProvider.stop(JmsResource resource,
AsyncResult request) |
void |
AmqpConnection.unsubscribe(String subscriptionName,
AsyncResult request) |
void |
AmqpConnectionSession.unsubscribe(String subscriptionName,
AsyncResult request)
Used to remove an existing durable topic subscription from the remote broker.
|
void |
AmqpProvider.unsubscribe(String subscription,
AsyncResult request) |
Constructor and Description |
---|
ScheduledStopRequest(ScheduledFuture<?> completionTask,
AsyncResult origRequest) |
Modifier and Type | Field and Description |
---|---|
protected AsyncResult |
AmqpResourceBuilder.request |
Modifier and Type | Method and Description |
---|---|
AsyncResult |
AmqpResourceBuilder.getRequest() |
Modifier and Type | Method and Description |
---|---|
void |
AmqpResourceBuilder.buildResource(AsyncResult request)
Called to initiate the process of building the resource type that is
managed by this builder.
|
void |
AmqpConnectionBuilder.buildResource(AsyncResult request) |
Modifier and Type | Class and Description |
---|---|
protected class |
FailoverProvider.CreateConnectionRequest
Captures the initial request to create a JmsConnectionInfo based resources and ensures
that if the connection is successfully established that the connection established event
is triggered once before moving on to sending only connection interrupted and restored
events.
|
protected class |
FailoverProvider.FailoverRequest
For all requests that are dispatched from the FailoverProvider to a connected
Provider instance an instance of FailoverRequest is used to handle errors that
occur during processing of that request and trigger a reconnect.
|
Modifier and Type | Method and Description |
---|---|
void |
FailoverProvider.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
FailoverProvider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
FailoverProvider.commit(JmsTransactionInfo transactionInfo,
AsyncResult request) |
void |
FailoverProvider.create(JmsResource resource,
AsyncResult request) |
void |
FailoverProvider.destroy(JmsResource resourceId,
AsyncResult request) |
void |
FailoverProvider.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request) |
void |
FailoverProvider.recover(JmsSessionId sessionId,
AsyncResult request) |
void |
FailoverProvider.rollback(JmsTransactionInfo transactionInfo,
AsyncResult request) |
void |
FailoverProvider.send(JmsOutboundMessageDispatch envelope,
AsyncResult request) |
void |
FailoverProvider.start(JmsResource resource,
AsyncResult request) |
void |
FailoverProvider.stop(JmsResource resource,
AsyncResult request) |
void |
FailoverProvider.unsubscribe(String subscription,
AsyncResult request) |
Constructor and Description |
---|
CreateConnectionRequest(AsyncResult watcher) |
FailoverRequest(AsyncResult watcher) |
FailoverRequest(AsyncResult watcher,
long requestTimeout) |
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.