Package | Description |
---|---|
com.rabbitmq.client |
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
|
com.rabbitmq.client.impl |
Implementations of interfaces specified in the client API, and their supporting classes.
|
com.rabbitmq.client.impl.nio |
NIO network connector.
|
com.rabbitmq.client.impl.recovery |
Implementation of connection and topology recovery.
|
com.rabbitmq.tools.jsonrpc |
JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport.
|
Class and Description |
---|
Address
A representation of network addresses, i.e.
|
AlreadyClosedException
Thrown when application tries to perform an action on connection/channel
which was already closed
|
AMQP |
AMQP.Access.Request |
AMQP.Access.RequestOk |
AMQP.Basic.Ack |
AMQP.Basic.Cancel |
AMQP.Basic.CancelOk |
AMQP.Basic.Consume |
AMQP.Basic.ConsumeOk |
AMQP.Basic.Deliver |
AMQP.Basic.Get |
AMQP.Basic.GetEmpty |
AMQP.Basic.GetOk |
AMQP.Basic.Nack |
AMQP.Basic.Publish |
AMQP.Basic.Qos |
AMQP.Basic.QosOk |
AMQP.Basic.Recover |
AMQP.Basic.RecoverAsync |
AMQP.Basic.RecoverOk |
AMQP.Basic.Reject |
AMQP.Basic.Return |
AMQP.BasicProperties |
AMQP.Channel.Close |
AMQP.Channel.CloseOk |
AMQP.Channel.Flow |
AMQP.Channel.FlowOk |
AMQP.Channel.Open |
AMQP.Channel.OpenOk |
AMQP.Confirm.Select |
AMQP.Confirm.SelectOk |
AMQP.Connection.Blocked |
AMQP.Connection.Close |
AMQP.Connection.CloseOk |
AMQP.Connection.Open |
AMQP.Connection.OpenOk |
AMQP.Connection.Secure |
AMQP.Connection.SecureOk |
AMQP.Connection.Start |
AMQP.Connection.StartOk |
AMQP.Connection.Tune |
AMQP.Connection.TuneOk |
AMQP.Connection.Unblocked |
AMQP.Connection.UpdateSecret |
AMQP.Connection.UpdateSecretOk |
AMQP.Exchange.Bind |
AMQP.Exchange.BindOk |
AMQP.Exchange.Declare |
AMQP.Exchange.DeclareOk |
AMQP.Exchange.Delete |
AMQP.Exchange.DeleteOk |
AMQP.Exchange.Unbind |
AMQP.Exchange.UnbindOk |
AMQP.Queue.Bind |
AMQP.Queue.BindOk |
AMQP.Queue.Declare |
AMQP.Queue.DeclareOk |
AMQP.Queue.Delete |
AMQP.Queue.DeleteOk |
AMQP.Queue.Purge |
AMQP.Queue.PurgeOk |
AMQP.Queue.Unbind |
AMQP.Queue.UnbindOk |
AMQP.Tx.Commit |
AMQP.Tx.CommitOk |
AMQP.Tx.Rollback |
AMQP.Tx.RollbackOk |
AMQP.Tx.Select |
AMQP.Tx.SelectOk |
BasicProperties |
BlockedCallback
Implement this interface in order to be notified of connection block events.
|
BlockedListener
Implement this interface in order to be notified of connection block and
unblock events.
|
BuiltinExchangeType
Enum for built-in exchange types.
|
CancelCallback
Callback interface to be notified of the cancellation of a consumer.
|
Channel
Interface to a channel.
|
ChannelContinuationTimeoutException
Exception thrown when a channel times out on a continuation during a RPC call.
|
Command
Interface to a container for an AMQP method-and-arguments, with optional content header and body.
|
ConfirmCallback
Implement this interface in order to be notified of Confirm events.
|
ConfirmListener
Implement this interface in order to be notified of Confirm events.
|
Connection
Public API: Interface to an AMQ connection.
|
Consumer
Interface for application callback objects to receive notifications and messages from
a queue by subscription.
|
ConsumerShutdownSignalCallback
Callback interface to be notified when either the consumer channel
or the underlying connection has been shut down.
|
ContentHeader
Public API for abstract AMQP content header objects.
|
DeliverCallback
Callback interface to be notified when a message is delivered.
|
ExceptionHandler
Interface to an exception-handling object.
|
GetResponse
Encapsulates the response from a
Channel.basicGet(java.lang.String, boolean) message-retrieval method call
- essentially a static bean "holder" with message response data. |
LongString
An object providing access to a LongString.
|
Method
Public interface to objects representing an AMQP 0-9-1 method
|
MetricsCollector
Interface to gather execution data of the client.
|
RecoveryDelayHandler
A RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts.
|
ReturnCallback
Implement this interface in order to be notified of failed
deliveries when basicPublish is called with "mandatory" or
"immediate" flags set.
|
ReturnListener
Implement this interface in order to be notified of failed
deliveries when basicPublish is called with "mandatory" or
"immediate" flags set.
|
SaslConfig
This interface represents a hook to allow you to control how exactly
a sasl client is selected during authentication.
|
SaslMechanism
Our own view of a SASL authentication mechanism, introduced to remove a
dependency on javax.security.sasl.
|
ShutdownListener
A ShutdownListener receives information about the shutdown of connections and
channels.
|
ShutdownNotifier
Interface for components that are shutdown capable and
that allow listeners to be added for shutdown signals
|
ShutdownSignalException
Encapsulates a shutdown condition for a connection to an AMQP broker.
|
SocketConfigurator |
SslContextFactory
A factory to create
SSLContext s. |
TopologyRecoveryException
Indicates an exception thrown during topology recovery.
|
TrafficListener
Contract to log outbound and inbound
Command s. |
UnblockedCallback
Implement this interface in order to be notified of connection unblock events.
|
Class and Description |
---|
Address
A representation of network addresses, i.e.
|
SocketChannelConfigurator |
SslContextFactory
A factory to create
SSLContext s. |
SslEngineConfigurator |
Class and Description |
---|
Address
A representation of network addresses, i.e.
|
AddressResolver
Strategy interface to get the potential servers to connect to.
|
AMQP.Basic.RecoverOk |
AMQP.BasicProperties |
AMQP.Confirm.SelectOk |
AMQP.Exchange.BindOk |
AMQP.Exchange.DeclareOk |
AMQP.Exchange.DeleteOk |
AMQP.Exchange.UnbindOk |
AMQP.Queue.BindOk |
AMQP.Queue.DeclareOk |
AMQP.Queue.DeleteOk |
AMQP.Queue.PurgeOk |
AMQP.Queue.UnbindOk |
AMQP.Tx.CommitOk |
AMQP.Tx.RollbackOk |
AMQP.Tx.SelectOk |
BlockedCallback
Implement this interface in order to be notified of connection block events.
|
BlockedListener
Implement this interface in order to be notified of connection block and
unblock events.
|
BuiltinExchangeType
Enum for built-in exchange types.
|
CancelCallback
Callback interface to be notified of the cancellation of a consumer.
|
Channel
Interface to a channel.
|
Command
Interface to a container for an AMQP method-and-arguments, with optional content header and body.
|
ConfirmCallback
Implement this interface in order to be notified of Confirm events.
|
ConfirmListener
Implement this interface in order to be notified of Confirm events.
|
Connection
Public API: Interface to an AMQ connection.
|
Consumer
Interface for application callback objects to receive notifications and messages from
a queue by subscription.
|
ConsumerShutdownSignalCallback
Callback interface to be notified when either the consumer channel
or the underlying connection has been shut down.
|
DeliverCallback
Callback interface to be notified when a message is delivered.
|
ExceptionHandler
Interface to an exception-handling object.
|
GetResponse
Encapsulates the response from a
Channel.basicGet(java.lang.String, boolean) message-retrieval method call
- essentially a static bean "holder" with message response data. |
Method
Public interface to objects representing an AMQP 0-9-1 method
|
MetricsCollector
Interface to gather execution data of the client.
|
Recoverable
Provides a way to register (network, AMQP 0-9-1) connection recovery
callbacks.
|
RecoverableChannel
Convenient interface when working against auto-recovery channels.
|
RecoverableConnection
Convenient interface when working against auto-recovery connections.
|
RecoveryListener
A RecoveryListener receives notifications about completed automatic connection
recovery.
|
ReturnCallback
Implement this interface in order to be notified of failed
deliveries when basicPublish is called with "mandatory" or
"immediate" flags set.
|
ReturnListener
Implement this interface in order to be notified of failed
deliveries when basicPublish is called with "mandatory" or
"immediate" flags set.
|
ShutdownListener
A ShutdownListener receives information about the shutdown of connections and
channels.
|
ShutdownNotifier
Interface for components that are shutdown capable and
that allow listeners to be added for shutdown signals
|
ShutdownSignalException
Encapsulates a shutdown condition for a connection to an AMQP broker.
|
UnblockedCallback
Implement this interface in order to be notified of connection unblock events.
|
Class and Description |
---|
AMQP.BasicProperties |
Channel
Interface to a channel.
|
RpcClient
Convenience class which manages simple RPC-style communication.
|
RpcClientParams
Holder class to configure a
RpcClient . |
RpcServer
Class which manages a request queue for a simple RPC-style service.
|
StringRpcServer
Subclass of RpcServer which accepts UTF-8 string requests.
|
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.