Table of Contents - amqp-1.6.0 Documentation
Pages
README
Ruby amqp gem: the asynchronous Ruby RabbitMQ client
A Word of Warning: Use This Only If You Already Use EventMachine
I know what RabbitMQ is, how do I get started?
What is RabbitMQ?
What is amqp gem good for?
Getting started with Ruby amqp gem
Install RabbitMQ
Install the gem
“Hello, World” example
Supported Ruby Versions
Documentation: tutorials, guides & API reference
Tutorials
Guides
Examples
API reference
How to use AMQP gem with Ruby on Rails, Sinatra and other Web frameworks
Community
Maintainer Information
Continuous Integration
Links
License
Credits and copyright information
How can I learn more about AMQP and messaging in general?
AMQP resources
Messaging and distributed systems resources
08Migration.textile
AMQP091ModelExplained.textile
Bindings.textile
Clustering.textile
ConnectingToTheBroker.textile
ConnectionEncryptionWithTLS.textile
INFO REPORT==== 28-Jun-2011::08:41:24 ===
INFO REPORT==== 28-Jun-2011::08:41:24 ===
INFO REPORT==== 28-Jun-2011::08:41:24 ===
DocumentationGuidesIndex.textile
Durability.textile
ErrorHandling.textile
Exchanges.textile
GettingStarted.textile
> true
> “0.9.0”
PatternsAndUseCases.textile
Queues.textile
> Subscribing for messages using explicit acknowledgements model
RabbitMQVersions.textile
RunningTests.textile
TestingWithEventedSpec.textile
Troubleshooting.textile
ERROR REPORT==== 17-May-2011::17:37:58 ===
ERROR REPORT==== 17-May-2011::17:26:28 ===
VendorSpecificExtensions.textile
Classes/Modules
AMQ
AMQ::Protocol
AMQ::Protocol::Basic
AMQ::Protocol::Channel
AMQ::Protocol::Confirm
AMQ::Protocol::Connection
AMQ::Protocol::Exchange
AMQ::Protocol::GetResponse
AMQ::Protocol::Queue
AMQ::Protocol::Tx
AMQP
AMQP::AuthMechanismAdapter
AMQP::AuthMechanismAdapter::External
AMQP::AuthMechanismAdapter::Plain
AMQP::Broker
AMQP::Callbacks
AMQP::Channel
AMQP::ChannelClosedError
AMQP::ChannelIdAllocator
AMQP::ConnectionClosedError
AMQP::Consumer
AMQP::ConsumerTagGenerator
AMQP::Entity
AMQP::Error
AMQP::Exchange
AMQP::Framing
AMQP::Framing::String
AMQP::Framing::String::Frame
AMQP::HandlersRegistry
AMQP::Header
AMQP::IncompatibleOptionsError
AMQP::Integration
AMQP::Integration::Rails
AMQP::Openable
AMQP::Openable::ImproperStatusError
AMQP::PossibleAuthenticationFailureError
AMQP::ProtocolMethodHandlers
AMQP::Queue
AMQP::RegisterEntityMixin
AMQP::ServerNamedEntity
AMQP::Session
AMQP::Settings
AMQP::TCPConnectionFailed
AMQP::Utilities
AMQP::Utilities::EventLoopHelper
AMQP::Utilities::ServerType
RbConfig
Methods
::add_default_options — AMQP::Queue
::add_default_options — AMQP::Exchange
::auth_mechanism — AMQP::AuthMechanismAdapter
::authentication_failure_exception_class — AMQP::Session
::channel — AMQP
::channel= — AMQP
::client_properties — AMQP::Settings
::closing? — AMQP
::configure — AMQP::Settings
::conn — AMQP
::conn= — AMQP
::connect — AMQP
::connect — AMQP::Session
::connection — AMQP
::connection= — AMQP
::consumer_class — AMQP::Queue
::decode — AMQP::Framing::String::Frame
::default — AMQP::Exchange
::default — AMQP::Settings
::detect — AMQP::Utilities::ServerType
::eventmachine_thread — AMQP::Utilities::EventLoopHelper
::find — AMQP::HandlersRegistry
::for_adapter — AMQP::AuthMechanismAdapter
::handle — AMQP::HandlersRegistry
::handlers — AMQP::HandlersRegistry
::logger — AMQP::Session
::logger= — AMQP::Session
::logging — AMQP
::logging — AMQP::Session
::logging= — AMQP::Session
::logging= — AMQP
::new — AMQ::Protocol::GetResponse
::new — AMQP::Session
::new — AMQP::Queue
::new — AMQP::Openable::ImproperStatusError
::new — AMQP::Header
::new — AMQP::Consumer
::new — AMQP::Channel
::new — AMQP::Broker
::new — AMQP::AuthMechanismAdapter
::new — AMQP::PossibleAuthenticationFailureError
::new — AMQP::Exchange
::new — AMQP::TCPConnectionFailed
::new — AMQP::ConnectionClosedError
::new — AMQP::ChannelClosedError
::new — AMQP::IncompatibleOptionsError
::new — AMQP::Entity
::parse_amqp_url — AMQP::Settings
::parse_connection_uri — AMQP::Settings
::reactor_running? — AMQP::Utilities::EventLoopHelper
::register — AMQP::HandlersRegistry
::registry — AMQP::AuthMechanismAdapter
::run — AMQP::Utilities::EventLoopHelper
::run — AMQP
::server_type — AMQP::Utilities::EventLoopHelper
::settings — AMQP::Session
::settings — AMQP
::start — AMQP
::start — AMQP::Integration::Rails
::stop — AMQP
::tag_generator — AMQP::Consumer
::tag_generator= — AMQP::Consumer
::tcp_connection_failure_exception_class — AMQP::Session
#ack — AMQP::Header
#acknowledge — AMQP::Channel
#acknowledge — AMQP::Consumer
#acknowledge — AMQP::Queue
#after_connection_interruption — AMQP::Consumer
#after_connection_interruption — AMQP::Channel
#after_connection_interruption — AMQP::Queue
#after_connection_interruption — AMQP::Session
#after_connection_interruption — AMQP::Exchange
#after_recovery — AMQP::Channel
#after_recovery — AMQP::Session
#after_recovery — AMQP::Queue
#after_recovery — AMQP::Exchange
#after_recovery — AMQP::Consumer
#anonymous? — AMQP::ServerNamedEntity
#append_callback — AMQP::Callbacks
#auth_mechanism_adapter — AMQP::Session
#authenticating? — AMQP::Session
#auto_deletable? — AMQP::Exchange
#auto_delete? — AMQP::Queue
#auto_deleted? — AMQP::Exchange
#auto_recover — AMQP::Queue
#auto_recover — AMQP::Exchange
#auto_recover — AMQP::Channel
#auto_recover — AMQP::Consumer
#auto_recover — AMQP::Session
#auto_recovering? — AMQP::Session
#auto_recovering? — AMQP::Channel
#auto_recovery? — AMQP::Session
#basic_consume — AMQP::Queue
#basic_publish — AMQP::Exchange
#before_recovery — AMQP::Session
#before_recovery — AMQP::Channel
#before_recovery — AMQP::Queue
#before_recovery — AMQP::Consumer
#before_recovery — AMQP::Exchange
#bind — AMQP::Exchange
#bind — AMQP::Queue
#broker — AMQP::Session
#broker_endpoint — AMQP::Session
#callback — AMQP::Consumer
#callback — AMQP::Queue
#callback — AMQP::Exchange
#cancel — AMQP::Queue
#cancel — AMQP::Consumer
#cancel_heartbeat_sender — AMQP::Session
#channel_id_mutex — AMQP::ChannelIdAllocator
#clear_callbacks — AMQP::Callbacks
#clear_frames_on — AMQP::Session
#close — AMQP::Channel
#close — AMQP::Session
#close_connection — AMQP::Session
#closed! — AMQP::Openable
#closed? — AMQP::Openable
#closing! — AMQP::Openable
#closing? — AMQP::Openable
#closing? — AMQP::Channel
#cluster_id — AMQ::Protocol::GetResponse
#confirm_select — AMQP::Channel
#connected? — AMQP::Session
#connection_completed — AMQP::Session
#connection_successful — AMQP::Session
#consume — AMQP::Consumer
#consumer_tag — AMQP::Header
#consumer_tag — AMQP::Queue
#consumers — AMQP::Channel
#content_complete? — AMQP::Session
#content_type — AMQP::Header
#correlation_id — AMQP::Header
#custom_type? — AMQP::Exchange
#default_exchange — AMQP::Channel
#define_callback — AMQP::Callbacks
#delete — AMQP::Queue
#delete — AMQP::Exchange
#delivery_mode — AMQP::Header
#delivery_tag — AMQ::Protocol::GetResponse
#delivery_tag — AMQP::Header
#direct — AMQP::Channel
#direct? — AMQP::Exchange
#disconnect — AMQP::Session
#disconnection_successful — AMQP::Session
#durable? — AMQP::Queue
#durable? — AMQP::Exchange
#empty? — AMQ::Protocol::GetResponse
#encode_credentials — AMQP::Session
#encode_credentials — AMQP::AuthMechanismAdapter::Plain
#encode_credentials — AMQP::AuthMechanismAdapter::External
#exchange — AMQ::Protocol::GetResponse
#exchange — AMQP::Queue
#exchange — AMQP::Header
#exchange_declare — AMQP::Exchange
#exchange_delete — AMQP::Exchange
#exchanges — AMQP::Channel
#exclusive? — AMQP::Queue
#exclusive? — AMQP::Consumer
#exec_callback — AMQP::Callbacks
#exec_callback_once — AMQP::Callbacks
#exec_callback_once_yielding_self — AMQP::Callbacks
#exec_callback_yielding_self — AMQP::Callbacks
#fanout — AMQP::Channel
#fanout? — AMQP::Exchange
#filtered_settings — AMQP::PossibleAuthenticationFailureError
#find_exchange — AMQP::Channel
#find_queue — AMQP::Channel
#flow — AMQP::Channel
#flow_is_active? — AMQP::Channel
#frameset_complete? — AMQP::Session
#generate — AMQP::ConsumerTagGenerator
#generate_consumer_tag — AMQP::Queue
#generate_for — AMQP::ConsumerTagGenerator
#get — AMQP::Queue
#get_next_frame — AMQP::Session
#handle — AMQP::ProtocolMethodHandlers
#handle_basic_ack — AMQP::Channel
#handle_basic_nack — AMQP::Channel
#handle_bind_ok — AMQP::Queue
#handle_bind_ok — AMQP::Exchange
#handle_cancel — AMQP::Consumer
#handle_cancel_ok — AMQP::Consumer
#handle_close — AMQP::Session
#handle_close — AMQP::Channel
#handle_close_ok — AMQP::Channel
#handle_close_ok — AMQP::Session
#handle_connection_blocked — AMQP::Session
#handle_connection_interruption — AMQP::Session
#handle_connection_interruption — AMQP::Channel
#handle_connection_interruption — AMQP::Exchange
#handle_connection_interruption — AMQP::Consumer
#handle_connection_interruption — AMQP::Queue
#handle_connection_unblocked — AMQP::Session
#handle_consume_ok — AMQP::Consumer
#handle_declare_ok — AMQP::Exchange
#handle_declare_ok — AMQP::Queue
#handle_delete_ok — AMQP::Exchange
#handle_delete_ok — AMQP::Queue
#handle_delivery — AMQP::Consumer
#handle_get_empty — AMQP::Queue
#handle_get_ok — AMQP::Queue
#handle_open_ok — AMQP::Session
#handle_open_ok — AMQP::Channel
#handle_purge_ok — AMQP::Queue
#handle_select_ok — AMQP::Channel
#handle_skipped_heartbeats — AMQP::Session
#handle_start — AMQP::Session
#handle_tune — AMQP::Session
#handle_unbind_ok — AMQP::Exchange
#handle_unbind_ok — AMQP::Queue
#handlers — AMQP::ProtocolMethodHandlers
#handshake — AMQP::Session
#has_callback? — AMQP::Callbacks
#header — AMQP::Header
#headers — AMQP::Header
#headers — AMQP::Channel
#headers? — AMQP::Exchange
#heartbeat_interval — AMQP::Session
#heartbeats_enabled? — AMQP::Session
#host — AMQP::Session
#hostname — AMQP::Session
#increment_publisher_index! — AMQP::Channel
#initialize_heartbeat_sender — AMQP::Session
#inspect — AMQP::Consumer
#int_allocator — AMQP::ChannelIdAllocator
#internal? — AMQP::Exchange
#message_count — AMQ::Protocol::GetResponse
#message_id — AMQP::Header
#method_missing — AMQP::Header
#negotiate_heartbeat_value — AMQP::Session
#next_channel_id — AMQP::ChannelIdAllocator
#on_ack — AMQP::Channel
#on_blocked — AMQP::Session
#on_cancel — AMQP::Consumer
#on_cancel — AMQP::Queue
#on_closed — AMQP::Session
#on_connection — AMQP::Session
#on_connection_interruption — AMQP::Channel
#on_connection_interruption — AMQP::Queue
#on_connection_interruption — AMQP::Session
#on_connection_interruption — AMQP::Exchange
#on_connection_interruption — AMQP::Consumer
#on_delivery — AMQP::Queue
#on_delivery — AMQP::Consumer
#on_disconnection — AMQP::Session
#on_error — AMQP::Channel
#on_error — AMQP::Session
#on_nack — AMQP::Channel
#on_open — AMQP::Session
#on_possible_authentication_failure — AMQP::Session
#on_recovery — AMQP::Consumer
#on_recovery — AMQP::Queue
#on_recovery — AMQP::Channel
#on_recovery — AMQP::Exchange
#on_recovery — AMQP::Session
#on_return — AMQP::Exchange
#on_skipped_heartbeats — AMQP::Session
#on_tcp_connection_failure — AMQP::Session
#on_tcp_connection_loss — AMQP::Session
#on_unblocked — AMQP::Session
#once_declared — AMQP::Queue
#once_name_is_available — AMQP::Queue
#once_open — AMQP::Channel
#once_opened — AMQP::Channel
#open — AMQP::Channel
#open — AMQP::Session
#open? — AMQP::Openable
#open? — AMQP::Channel
#opened! — AMQP::Openable
#opened? — AMQP::Openable
#opening! — AMQP::Openable
#opening? — AMQP::Openable
#periodically_reconnect — AMQP::Session
#pop — AMQP::Queue
#port — AMQP::Session
#post_init — AMQP::Session
#predefined? — AMQP::Exchange
#prefetch — AMQP::Channel
#prepend_callback — AMQP::Callbacks
#priority — AMQP::Header
#product — AMQP::Broker
#publish — AMQP::Queue
#publish — AMQP::Exchange
#publisher_index — AMQP::Channel
#purge — AMQP::Queue
#qos — AMQP::Channel
#queue — AMQP::Channel
#queue! — AMQP::Channel
#queue_bind — AMQP::Queue
#queue_declare — AMQP::Queue
#queue_delete — AMQP::Queue
#queue_purge — AMQP::Queue
#queue_unbind — AMQP::Queue
#queues — AMQP::Channel
#rabbitmq? — AMQP::Broker
#rebind — AMQP::Queue
#receive_data — AMQP::Session
#receive_frame — AMQP::Session
#receive_frameset — AMQP::Session
#reconnect — AMQP::Session
#reconnect_to — AMQP::Session
#reconnecting? — AMQP::Session
#recover — AMQP::Channel
#redeclare — AMQP::Queue
#redeclare — AMQP::Exchange
#redefine_callback — AMQP::Callbacks
#redelivered — AMQP::Header
#redelivered — AMQ::Protocol::GetResponse
#redelivered? — AMQP::Header
#register_connection_callback — AMQP::Session
#register_entity — AMQP::RegisterEntityMixin
#register_exchange — AMQP::Channel
#register_queue — AMQP::Channel
#register_with_channel — AMQP::Consumer
#register_with_queue — AMQP::Consumer
#reject — AMQP::Header
#reject — AMQP::Queue
#reject — AMQP::Channel
#reject — AMQP::Consumer
#release_channel_id — AMQP::ChannelIdAllocator
#reopen — AMQP::Channel
#reply_to — AMQP::Header
#reset — AMQP::Channel
#reset — AMQP::Queue
#reset — AMQP::Exchange
#reset — AMQP::Session
#reset_channel_id_allocator — AMQP::ChannelIdAllocator
#reset_publisher_index! — AMQP::Channel
#reset_state! — AMQP::Channel
#reset_state! — AMQP::Session
#resubscribe — AMQP::Consumer
#reuse — AMQP::Channel
#routing_key — AMQ::Protocol::GetResponse
#run_after_recovery_callbacks — AMQP::Queue
#run_after_recovery_callbacks — AMQP::Channel
#run_after_recovery_callbacks — AMQP::Session
#run_after_recovery_callbacks — AMQP::Exchange
#run_after_recovery_callbacks — AMQP::Consumer
#run_before_recovery_callbacks — AMQP::Channel
#run_before_recovery_callbacks — AMQP::Exchange
#run_before_recovery_callbacks — AMQP::Queue
#run_before_recovery_callbacks — AMQP::Session
#run_before_recovery_callbacks — AMQP::Consumer
#run_skipped_heartbeats_callbacks — AMQP::Session
#send_frame — AMQP::Session
#send_frameset — AMQP::Session
#send_heartbeat — AMQP::Session
#send_preamble — AMQP::Session
#server_named? — AMQP::Queue
#server_named? — AMQP::ServerNamedEntity
#start_automatic_recovery — AMQP::Session
#status — AMQP::Queue
#status= — AMQP::Openable
#subscribe — AMQP::Queue
#subscribed? — AMQP::Queue
#subscribed? — AMQP::Consumer
#supports_basic_nack? — AMQP::Broker
#supports_consumer_cancel_notifications? — AMQP::Broker
#supports_exchange_to_exchange_bindings? — AMQP::Broker
#supports_publisher_confirmations? — AMQP::Broker
#synchronize — AMQP::Channel
#tcp_connection_established? — AMQP::Session
#tcp_connection_failed — AMQP::Session
#tcp_connection_lost — AMQP::Session
#temporary? — AMQP::Exchange
#timestamp — AMQP::Header
#to_hash — AMQP::Header
#to_s — AMQP::Consumer
#topic — AMQP::Channel
#topic? — AMQP::Exchange
#transient? — AMQP::Exchange
#tx_commit — AMQP::Channel
#tx_rollback — AMQP::Channel
#tx_select — AMQP::Channel
#type — AMQP::Header
#unbind — AMQP::Session
#unbind — AMQP::Exchange
#unbind — AMQP::Queue
#unregister_with_channel — AMQP::Consumer
#unregister_with_queue — AMQP::Consumer
#unsubscribe — AMQP::Queue
#upgrade_to_tls_if_necessary — AMQP::Session
#user — AMQP::Session
#username — AMQP::Session
#uses_publisher_confirmations? — AMQP::Channel
#validate_parameters_match! — AMQP::Channel
#version — AMQP::Broker
#vhost — AMQP::Session