The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.
Interface Summary Interface Description AddressResolverStrategy interface to get the potential servers to connect to. 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.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 BlockedCallbackImplement this interface in order to be notified of connection block events. BlockedListenerImplement this interface in order to be notified of connection block and unblock events. CancelCallbackCallback interface to be notified of the cancellation of a consumer. ChannelInterface to a channel. CommandInterface to a container for an AMQP method-and-arguments, with optional content header and body. ConfirmCallbackImplement this interface in order to be notified of Confirm events. ConfirmListenerImplement this interface in order to be notified of Confirm events. ConnectionPublic API: Interface to an AMQ connection. ConsumerInterface for application callback objects to receive notifications and messages from a queue by subscription. ConsumerShutdownSignalCallbackCallback interface to be notified when either the consumer channel or the underlying connection has been shut down. ContentHeaderPublic API for abstract AMQP content header objects. DeliverCallbackCallback interface to be notified when a message is delivered. ExceptionHandlerInterface to an exception-handling object. LongStringAn object providing access to a LongString. MethodPublic interface to objects representing an AMQP 0-9-1 method MetricsCollectorInterface to gather execution data of the client. RecoverableProvides a way to register (network, AMQP 0-9-1) connection recovery callbacks. RecoverableChannelConvenient interface when working against auto-recovery channels. RecoverableConnectionConvenient interface when working against auto-recovery connections. RecoveryDelayHandlerA RecoveryDelayHandler is used to tell automatic recovery how long to sleep between reconnect attempts. RecoveryListenerA RecoveryListener receives notifications about completed automatic connection recovery. ReturnCallbackImplement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set. ReturnListenerImplement this interface in order to be notified of failed deliveries when basicPublish is called with "mandatory" or "immediate" flags set. RpcServer.RpcConsumer SaslConfigThis interface represents a hook to allow you to control how exactly a sasl client is selected during authentication. SaslMechanismOur own view of a SASL authentication mechanism, introduced to remove a dependency on javax.security.sasl. ShutdownListenerA ShutdownListener receives information about the shutdown of connections and channels. ShutdownNotifierInterface for components that are shutdown capable and that allow listeners to be added for shutdown signals SocketChannelConfigurator SocketConfigurator SslContextFactoryA factory to create
SslEngineConfigurator TrafficListenerContract to log outbound and inbound
UnblockedCallbackImplement this interface in order to be notified of connection unblock events.
Enum Summary Enum Description BuiltinExchangeTypeEnum for built-in exchange types.
Exception Summary Exception Description AlreadyClosedExceptionThrown when application tries to perform an action on connection/channel which was already closed AuthenticationFailureExceptionThrown when the broker refuses access due to an authentication failure. ChannelContinuationTimeoutExceptionException thrown when a channel times out on a continuation during a RPC call. ConsumerCancelledException MalformedFrameExceptionEncapsulates a frame format error at the wire level. MissedHeartbeatExceptionEncapsulates an exception indicating that the connection has missed too many heartbeats and is being shut down. PossibleAuthenticationFailureExceptionThrown when the likely cause is an authentication failure. ProtocolVersionMismatchExceptionThrown to indicate that the server does not support the wire protocol version we requested immediately after opening the TCP socket. ShutdownSignalExceptionEncapsulates a shutdown condition for a connection to an AMQP broker. TopologyRecoveryExceptionIndicates an exception thrown during topology recovery. UnexpectedFrameErrorThrown when the command parser hits an unexpected frame type. UnexpectedMethodErrorIndicates that a
Methodobject was supplied that was not expected.
UnknownClassOrMethodIdThrown when the protocol handlers detect an unknown class number or method number. UnroutableRpcRequestExceptionException thrown when a RPC request isn't routed to any queue.