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 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.._channelMax
).Main interface to AMQP protocol functionality.Publicly available Client Version informationClass 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.Parses an AMQP wire-protocolContentHeader
from 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 aCredentialsProvider
and its registered entities.Builder to create instances ofDefaultCredentialsRefreshService.DefaultCredentialsRefreshServiceBuilder
.Default implementation ofExceptionHandler
used 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 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
.Utility for working withLongString
s.Private API - Implementation ofLongString
.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
.The PLAIN auth mechanismAn abstractCredentialsProvider
that 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 managesShutdownListener
s and remembers the reason for a shutdown.A socket-based frame handler.An implementation ofExceptionHandler
that 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-secret
extensionMethod
.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 whenWorkPool
enqueueing times out.