Uses of Package
com.rabbitmq.client.impl
Packages that use 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.
-
Classes in com.rabbitmq.client.impl used by com.rabbitmq.clientClassDescriptionConcrete 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 -
Classes in com.rabbitmq.client.impl used by com.rabbitmq.client.implClassDescriptionBase class modelling an AMQ channel.AMQP 0-9-1-specific implementation of
Command
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.._channelMax
).Main interface to AMQP protocol functionality.Class responsible for piecing together a command from a series ofFrame
s.Current state, used to decide how to handle each incoming frame.Dispatches notifications to aConsumer
on an internally-managed executor service and work pool.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
.State and refresh behavior for aCredentialsProvider
and its registered entities.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.Manages heartbeat sending for aAMQConnection
.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 generic queue-like implementation (supporting operationsaddIfNotPresent
,poll
,contains
, andisEmpty
) which restricts a queue element to appear at most once.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.A clone of LinkedBlockingQueue with the addition of aVariableLinkedBlockingQueue.setCapacity(int)
method, allowing us to change the capacity of the queue while it is in use.Linked list node classEncapsulation of AMQP protocol versionThis is a generic implementation of the channels specification in Channeling Work, Nov 2010 (channels.pdf). -
Classes in com.rabbitmq.client.impl used by com.rabbitmq.client.impl.nioClassDescriptionConcrete 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.
-
Classes in com.rabbitmq.client.impl used by com.rabbitmq.client.impl.recoveryClassDescriptionBase 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.._channelMax
).Main interface to AMQP protocol functionality.Interface to a frame handler.A class that managesShutdownListener
s and remembers the reason for a shutdown.