Package com.rabbitmq.client.impl
package com.rabbitmq.client.impl
Implementations of interfaces specified in the client API, and their supporting classes.
-
ClassDescriptionBase class for
MetricsCollector.Base class modelling an AMQ channel.AMQP 0-9-1-specific implementation ofCommandwhich 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.Publicly available Client Version informationClass 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.Parses an AMQP wire-protocolContentHeaderfrom a DataInputStream.Generates an AMQP wire-protocol packet from aContentHeader.Provides equivalent security to PLAIN but demos use of Connection.Secure(Ok) START-OK: Username SECURE: "Please tell me your password" SECURE-OK: PasswordProvider 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.Default implementation of a CredentialsProvider which simply holds a static username and password.Scheduling-based implementation ofCredentialsRefreshService.State and refresh behavior for aCredentialsProviderand its registered entities.Builder to create instances ofDefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder.Default implementation ofExceptionHandlerused byAMQConnection.Infers information about the execution environment, e.g.Listener called when a connection gets an IO error trying to write on the socket.The EXTERNAL auth mechanismAn 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.Utility for working withLongStrings.Private API - Implementation ofLongString.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.The PLAIN auth mechanismAn abstractCredentialsProviderthat does not let token refresh happen concurrently.SetQueue<T>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.A socket-based frame handler.An implementation ofExceptionHandlerthat does close channels on unhandled consumer exception.Utility to extract information from X509 certificates.Utility stream: proxies another stream, making it appear to be no longer than a preset limit.Helper forupdate-secretextensionMethod.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 versionWorkPool<K,W> This is a generic implementation of the channels specification in Channeling Work, Nov 2010 (channels.pdf).Exception thrown whenWorkPoolenqueueing times out.