Package com.rabbitmq.client.impl
package com.rabbitmq.client.impl
-
ClassDescriptionBase class modelling an AMQ channel.AMQ-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.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: PasswordDefault implementation ofExceptionHandlerused byAMQConnection.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.The PLAIN auth mechanismSetQueue<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 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 theChannels
specification in Channeling Work, Nov 2010 (channels.pdf).