Module AMQ::Client
In: lib/amq/client/exchange.rb
lib/amq/client/settings.rb
lib/amq/client/extensions/rabbitmq/basic.rb
lib/amq/client/extensions/rabbitmq/confirm.rb
lib/amq/client/entity.rb
lib/amq/client/adapter.rb
lib/amq/client/handlers_registry.rb
lib/amq/client/openable.rb
lib/amq/client/consumer_tag_generator.rb
lib/amq/client/version.rb
lib/amq/client/channel.rb
lib/amq/client/async/consumer.rb
lib/amq/client/async/callbacks.rb
lib/amq/client/async/extensions/rabbitmq/confirm.rb
lib/amq/client/async/extensions/rabbitmq/basic.rb
lib/amq/client/async/queue.rb
lib/amq/client/async/entity.rb
lib/amq/client/async/adapters/event_machine.rb
lib/amq/client/async/adapters/coolio.rb
lib/amq/client/async/channel.rb
lib/amq/client/async/exchange.rb
lib/amq/client/async/adapter.rb
lib/amq/client/framing/string/frame.rb
lib/amq/client/framing/io/frame.rb
lib/amq/client/adapters/coolio.rb
lib/amq/client/adapters/event_machine.rb
lib/amq/client/logging.rb
lib/amq/client/queue.rb
lib/amq/client/callbacks.rb
lib/amq/client/exceptions.rb
lib/amq/client/server_named_entity.rb
lib/amq/client.rb

For overview of AMQP client adapters API, see {AMQ::Client::Adapter}

Methods

Classes and Modules

Module AMQ::Client::Async
Module AMQ::Client::Framing
Module AMQ::Client::Logging
Module AMQ::Client::Openable
Module AMQ::Client::ServerNamedEntity
Module AMQ::Client::Settings
Class AMQ::Client::BadLengthError
Class AMQ::Client::ConnectionClosedError
Class AMQ::Client::ConsumerTagGenerator
Class AMQ::Client::HandlersRegistry
Class AMQ::Client::InconsistentDataError
Class AMQ::Client::MissingHandlerError
Class AMQ::Client::NoFinalOctetError
Class AMQ::Client::PossibleAuthenticationFailureError
Class AMQ::Client::TCPConnectionFailed
Class AMQ::Client::UnknownExchangeTypeError

Constants

Exchange = Async::Exchange   backwards compatibility @private
Extensions = Async::Extensions unless defined?(Extensions)   backwards compatibility @private
Extensions = Async::Extensions unless defined?(Extensions)   backwards compatibility @private
RegisterEntityMixin = Async::RegisterEntityMixin   backwards compatibility @private
ProtocolMethodHandlers = Async::ProtocolMethodHandlers
Entity = Async::Entity
Adapter = Async::Adapter   backwards compatibility @private
VERSION = "0.9.4"
Channel = Async::Channel   backwards compatibility @private
CoolioClient = Async::CoolioClient   backwards compatibility @private
EventMachineClient = Async::EventMachineClient   backwards compatibility @private
Queue = Async::Queue
Callbacks = Async::Callbacks   backwards compatibility @private

Public Class methods

List available adapters as a hash of { :adapter_name => metadata }, where metadata are hash with :path and :const_name keys.

@return [Hash] @api plugin

List available asynchronous adapters.

@return [Hash] @api plugin @see AMQ::Client.adapters

Establishes connection to AMQ broker using given adapter (defaults to the socket adapter) and returns it. The new connection object is yielded to the block if it is given.

@example

  AMQ::Client.connect(adapter: "socket") do |client|
    # Use the client.
  end

@param [Hash] Connection parameters, including :adapter to use. @api public

Loads adapter given its name as a Symbol.

@raise [InvalidAdapterNameError] When loading attempt failed (LoadError was raised).

[Validate]