Search Java Classes and Packages
#Com.rabbitmq.client.impl Classes and Interfaces - 130 results found.
| Name | Description | Type | Package | Framework |
| AMQBasicProperties | Class | com.rabbitmq.client.impl | RabbitMQ | |
| AMQChannel | Base class modelling an AMQ channel. | Class | com.rabbitmq.client.impl | RabbitMQ |
| AMQChannel .BlockingRpcContinuation | Class | com.rabbitmq.client.impl.AMQChannel | RabbitMQ | |
| AMQChannel .RpcContinuation | Interface | com.rabbitmq.client.impl.AMQChannel | RabbitMQ | |
| AMQChannel .SimpleBlockingRpcContinuation | Class | com.rabbitmq.client.impl.AMQChannel | RabbitMQ | |
| AMQCommand | AMQ-specific implementation of Command which accumulates method, header and body from a series of frames, unless these are | Class | com.rabbitmq.client.impl | RabbitMQ |
| AMQConnection | Concrete class representing and managing an AMQP connection to a broker. | Class | com.rabbitmq.client.impl | RabbitMQ |
| AMQContentHeader | Class | com.rabbitmq.client.impl | RabbitMQ | |
| AMQImpl | Class | com.rabbitmq.client.impl | RabbitMQ | |
| AMQImpl .Access | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Access .Request | Class | com.rabbitmq.client.impl.AMQImpl.Access | RabbitMQ | |
| AMQImpl .Access .RequestOk | Class | com.rabbitmq.client.impl.AMQImpl.Access | RabbitMQ | |
| AMQImpl .Basic | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Basic .Ack | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Cancel | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .CancelOk | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Consume | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .ConsumeOk | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Deliver | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Get | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .GetEmpty | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .GetOk | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Nack | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Publish | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Qos | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .QosOk | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Recover | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .RecoverAsync | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .RecoverOk | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Reject | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Basic .Return | Class | com.rabbitmq.client.impl.AMQImpl.Basic | RabbitMQ | |
| AMQImpl .Channel | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Channel .Close | Class | com.rabbitmq.client.impl.AMQImpl.Channel | RabbitMQ | |
| AMQImpl .Channel .CloseOk | Class | com.rabbitmq.client.impl.AMQImpl.Channel | RabbitMQ | |
| AMQImpl .Channel .Flow | Class | com.rabbitmq.client.impl.AMQImpl.Channel | RabbitMQ | |
| AMQImpl .Channel .FlowOk | Class | com.rabbitmq.client.impl.AMQImpl.Channel | RabbitMQ | |
| AMQImpl .Channel .Open | Class | com.rabbitmq.client.impl.AMQImpl.Channel | RabbitMQ | |
| AMQImpl .Channel .OpenOk | Class | com.rabbitmq.client.impl.AMQImpl.Channel | RabbitMQ | |
| AMQImpl .Confirm | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Confirm .Select | Class | com.rabbitmq.client.impl.AMQImpl.Confirm | RabbitMQ | |
| AMQImpl .Confirm .SelectOk | Class | com.rabbitmq.client.impl.AMQImpl.Confirm | RabbitMQ | |
| AMQImpl .Connection | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Connection .Blocked | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .Close | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .CloseOk | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .Open | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .OpenOk | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .Secure | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .SecureOk | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .Start | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .StartOk | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .Tune | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .TuneOk | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .Connection .Unblocked | Class | com.rabbitmq.client.impl.AMQImpl.Connection | RabbitMQ | |
| AMQImpl .DefaultMethodVisitor | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Exchange | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Exchange .Bind | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .Exchange .BindOk | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .Exchange .Declare | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .Exchange .DeclareOk | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .Exchange .Delete | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .Exchange .DeleteOk | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .Exchange .Unbind | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .Exchange .UnbindOk | Class | com.rabbitmq.client.impl.AMQImpl.Exchange | RabbitMQ | |
| AMQImpl .MethodVisitor | Interface | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Queue | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Queue .Bind | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .BindOk | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .Declare | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .DeclareOk | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .Delete | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .DeleteOk | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .Purge | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .PurgeOk | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .Unbind | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Queue .UnbindOk | Class | com.rabbitmq.client.impl.AMQImpl.Queue | RabbitMQ | |
| AMQImpl .Tx | Class | com.rabbitmq.client.impl.AMQImpl | RabbitMQ | |
| AMQImpl .Tx .Commit | Class | com.rabbitmq.client.impl.AMQImpl.Tx | RabbitMQ | |
| AMQImpl .Tx .CommitOk | Class | com.rabbitmq.client.impl.AMQImpl.Tx | RabbitMQ | |
| AMQImpl .Tx .Rollback | Class | com.rabbitmq.client.impl.AMQImpl.Tx | RabbitMQ | |
| AMQImpl .Tx .RollbackOk | Class | com.rabbitmq.client.impl.AMQImpl.Tx | RabbitMQ | |
| AMQImpl .Tx .Select | Class | com.rabbitmq.client.impl.AMQImpl.Tx | RabbitMQ | |
| AMQImpl .Tx .SelectOk | Class | com.rabbitmq.client.impl.AMQImpl.Tx | RabbitMQ | |
| AutorecoveringChannel | Channel implementation that is automatically recovered during connection recovery. | Class | com.rabbitmq.client.impl.recovery | RabbitMQ |
| AutorecoveringConnection | Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e. | Class | com.rabbitmq.client.impl.recovery | RabbitMQ |
| ChannelManager | Manages a set of channels, indexed by channel number (1. | Class | com.rabbitmq.client.impl | RabbitMQ |
| ChannelN | Main interface to AMQP protocol functionality. | Class | com.rabbitmq.client.impl | RabbitMQ |
| ClientVersion | Class | com.rabbitmq.client.impl | RabbitMQ | |
| ConnectionParams | Class | com.rabbitmq.client.impl | RabbitMQ | |
| ConsumerRecoveryListener | Not part of the public API. | Interface | com.rabbitmq.client.impl.recovery | RabbitMQ |
| ConsumerWorkService | Class | com.rabbitmq.client.impl | RabbitMQ | |
| ContentHeaderPropertyReader | Parses an AMQP wire-protocol ContentHeader from a DataInputStream. | Class | com.rabbitmq.client.impl | RabbitMQ |
| ContentHeaderPropertyWriter | Generates an AMQP wire-protocol packet from a ContentHeader. | Class | com.rabbitmq.client.impl | RabbitMQ |
| CRDemoMechanism | Provides equivalent security to PLAIN but demos use of Connection. | Class | com.rabbitmq.client.impl | RabbitMQ |
| CRDemoMechanism .CRDemoSaslConfig | Class | com.rabbitmq.client.impl.CRDemoMechanism | RabbitMQ | |
| DefaultExceptionHandler | Default implementation of ExceptionHandler used by AMQConnection. | Class | com.rabbitmq.client.impl | RabbitMQ |
| ExternalMechanism | Class | com.rabbitmq.client.impl | RabbitMQ | |
| ForgivingExceptionHandler | An implementation of ExceptionHandler that does not close channels on unhandled consumer and listener exception. | Class | com.rabbitmq.client.impl | RabbitMQ |
| Frame | Represents an AMQP wire-protocol frame, with frame type, channel number, and payload bytes. | Class | com.rabbitmq.client.impl | RabbitMQ |
| FrameHandler | Interface to a frame handler. | Interface | com.rabbitmq.client.impl | RabbitMQ |
| FrameHandlerFactory | Class | com.rabbitmq.client.impl | RabbitMQ | |
| LongStringHelper | Utility for working with LongStrings. | Class | com.rabbitmq.client.impl | RabbitMQ |
| Method | Class | com.rabbitmq.client.impl | RabbitMQ | |
| MethodArgumentReader | Parses AMQP wire-protocol Method arguments from a DataInputStream. | Class | com.rabbitmq.client.impl | RabbitMQ |
| MethodArgumentWriter | Generates AMQP wire-protocol encoded arguments. | Class | com.rabbitmq.client.impl | RabbitMQ |
| NetworkConnection | Interface | com.rabbitmq.client.impl | RabbitMQ | |
| PlainMechanism | Class | com.rabbitmq.client.impl | RabbitMQ | |
| QueueRecoveryListener | Not part of the public API. | Interface | com.rabbitmq.client.impl.recovery | RabbitMQ |
| RecordedBinding | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecordedConsumer | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecordedEntity | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecordedExchange | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecordedExchangeBinding | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecordedNamedEntity | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecordedQueue | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecordedQueueBinding | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecoveryAwareAMQConnection | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecoveryAwareAMQConnectionFactory | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecoveryAwareChannelManager | Class | com.rabbitmq.client.impl.recovery | RabbitMQ | |
| RecoveryAwareChannelN | ChannelN modification that keeps track of delivery tags and avoids sending basic. | Class | com.rabbitmq.client.impl.recovery | RabbitMQ |
| SetQueue | A generic queue-like implementation (supporting operations addIfNotPresent, poll, contains, and isEmpty) | Class | com.rabbitmq.client.impl | RabbitMQ |
| ShutdownNotifierComponent | A class that manages ShutdownListeners and remembers the reason for a shutdown. | Class | com.rabbitmq.client.impl | RabbitMQ |
| SocketFrameHandler | A socket-based frame handler. | Class | com.rabbitmq.client.impl | RabbitMQ |
| StrictExceptionHandler | An implementation of ExceptionHandler that does close channels on unhandled consumer exception. | Class | com.rabbitmq.client.impl | RabbitMQ |
| TruncatedInputStream | Utility stream: proxies another stream, making it appear to be no longer than a preset limit. | Class | com.rabbitmq.client.impl | RabbitMQ |
| ValueReader | Helper class to read AMQP wire-protocol encoded values. | Class | com.rabbitmq.client.impl | RabbitMQ |
| ValueWriter | Helper class to generate AMQP wire-protocol encoded values. | Class | com.rabbitmq.client.impl | RabbitMQ |
| VariableLinkedBlockingQueue | A clone of LinkedBlockingQueue with the addition of a setCapacity(int) method, allowing us to | Class | com.rabbitmq.client.impl | RabbitMQ |
| Version | Class | com.rabbitmq.client.impl | RabbitMQ | |
| WorkPool | This is a generic implementation of the Channels specification in Channeling Work, Nov 2010 (channels. | Class | com.rabbitmq.client.impl | RabbitMQ |