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
Commandwhich 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 ofFrames.Current state, used to decide how to handle each incoming frame.Dispatches notifications to aConsumeron 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 aCredentialsProviderand 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 ofExceptionHandlerthat 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-protocolMethodarguments from a DataInputStream.Generates AMQP wire-protocol encoded arguments.ACredentialsProviderthat performs an OAuth 2 Client Credentials flow to retrieve a token.Helper to createOAuth2ClientCredentialsGrantCredentialsProviderinstances.TLS configuration for aOAuth2ClientCredentialsGrantCredentialsProvider.An abstractCredentialsProviderthat 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 managesShutdownListeners and remembers the reason for a shutdown.An implementation ofExceptionHandlerthat 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 managesShutdownListeners and remembers the reason for a shutdown.