For overview of AMQP client adapters API, see {AMQ::Client::Adapter}
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 |
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