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
- DocumentationGuidesIndex.textile
- Durability.textile
- ErrorHandling.textile
- Exchanges.textile
- GettingStarted.textile
- PatternsAndUseCases.textile
- Queues.textile
- RabbitMQVersions.textile
- RunningTests.textile
- TestingWithEventedSpec.textile
- Troubleshooting.textile
- VendorSpecificExtensions.textile
Classes and 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