Uses of Package
com.rabbitmq.client.impl
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
Implementations of interfaces specified in the client API, and their supporting classes.
NIO network connector.
Implementation of connection and topology recovery.
-
ClassDescriptionConcrete class representing and managing an AMQP connection to a broker.Implementation of ContentHeader - specialized by autogenerated code in AMQP.java.Generates an AMQP wire-protocol packet from a
ContentHeader
.Provider interface for establishing credentials for connecting to the broker.Provider interface to refresh credentials when appropriate and perform an operation once the credentials have been renewed.Listener called when a connection gets an IO error trying to write on the socket.Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.Interface to a frame handler.Encapsulation of AMQP protocol version -
ClassDescriptionBase class for
MetricsCollector
.Base class modelling an AMQ channel.AMQP 0-9-1-specific implementation ofCommand
which accumulates method, header and body from a series of frames, unless these are supplied at construction time.Concrete class representing and managing an AMQP connection to a broker.Implementation of ContentHeader - specialized by autogenerated code in AMQP.java.Manages a set of channels, indexed by channel number (1..
Main interface to AMQP protocol functionality.Generates an AMQP wire-protocol packet from aContentHeader
.Provider interface for establishing credentials for connecting to the broker.Provider interface to refresh credentials when appropriate and perform an operation once the credentials have been renewed.Scheduling-based implementation ofCredentialsRefreshService
.Builder to create instances ofDefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder
.Listener called when a connection gets an IO error trying to write on the socket.An implementation ofExceptionHandler
that does not close channels on unhandled consumer and listener exception.Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.Interface to a frame handler.Base class for AMQP method objects, specialized by autogenerated code in AMQP.java.Parses AMQP wire-protocolMethod
arguments from a DataInputStream.Generates AMQP wire-protocol encoded arguments.ACredentialsProvider
that performs an OAuth 2 Client Credentials flow to retrieve a token.Helper to createOAuth2ClientCredentialsGrantCredentialsProvider
instances.TLS configuration for aOAuth2ClientCredentialsGrantCredentialsProvider
.An abstractCredentialsProvider
that does not let token refresh happen concurrently.A class that managesShutdownListener
s and remembers the reason for a shutdown.An implementation ofExceptionHandler
that does close channels on unhandled consumer exception.Helper class to read AMQP wire-protocol encoded values.Helper class to generate AMQP wire-protocol encoded values.Encapsulation of AMQP protocol version -
ClassDescriptionConcrete class representing and managing an AMQP connection to a broker.Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes.Interface to a frame handler.
-
ClassDescriptionBase class modelling an AMQ channel.Concrete class representing and managing an AMQP connection to a broker.Manages a set of channels, indexed by channel number (
1..
Main interface to AMQP protocol functionality.Interface to a frame handler.A class that managesShutdownListener
s and remembers the reason for a shutdown.