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 informationParses 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.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.Utility for working withLongStrings.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.Micrometer implementation ofMetricsCollector.ACredentialsProviderthat performs an OAuth 2 Client Credentials flow to retrieve a token.Helper to createOAuth2ClientCredentialsGrantCredentialsProviderinstances.TLS configuration for aOAuth2ClientCredentialsGrantCredentialsProvider.OpenTelemetry implementation ofMetricsCollector.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.Dropwizard Metrics implementation ofMetricsCollector.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 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.Encapsulation 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.