Module: RabbitMQ

Defined in:: lib/rabbitmq.rb,
lib/rabbitmq/ffi.rb,
lib/rabbitmq/util.rb,
lib/rabbitmq/client.rb,
lib/rabbitmq/channel.rb,
lib/rabbitmq/ffi/error.rb,
lib/rabbitmq/server_error.rb,
lib/rabbitmq/ffi/ext/array.rb,
lib/rabbitmq/ffi/ext/bytes.rb,
lib/rabbitmq/ffi/ext/frame.rb,
lib/rabbitmq/ffi/ext/table.rb,
lib/rabbitmq/ffi/ext/method.rb,
lib/rabbitmq/ffi/ext/timeval.rb,
lib/rabbitmq/client/connection.rb,
lib/rabbitmq/ffi/gen/basic_ack.rb,
lib/rabbitmq/ffi/gen/basic_get.rb,
lib/rabbitmq/ffi/gen/basic_qos.rb,
lib/rabbitmq/ffi/gen/tx_commit.rb,
lib/rabbitmq/ffi/gen/tx_select.rb,
lib/rabbitmq/ffi/gen/basic_nack.rb,
lib/rabbitmq/ffi/gen/queue_bind.rb,
lib/rabbitmq/ffi/ext/field_value.rb,
lib/rabbitmq/ffi/gen/queue_purge.rb,
lib/rabbitmq/ffi/gen/tx_rollback.rb,
lib/rabbitmq/ffi/gen/basic_cancel.rb,
lib/rabbitmq/ffi/gen/basic_get_ok.rb,
lib/rabbitmq/ffi/gen/basic_qos_ok.rb,
lib/rabbitmq/ffi/gen/basic_reject.rb,
lib/rabbitmq/ffi/gen/basic_return.rb,
lib/rabbitmq/ffi/gen/channel_flow.rb,
lib/rabbitmq/ffi/gen/channel_open.rb,
lib/rabbitmq/ffi/gen/queue_delete.rb,
lib/rabbitmq/ffi/gen/queue_unbind.rb,
lib/rabbitmq/ffi/gen/tx_commit_ok.rb,
lib/rabbitmq/ffi/gen/tx_select_ok.rb,
lib/rabbitmq/ffi/gen/basic_consume.rb,
lib/rabbitmq/ffi/gen/basic_deliver.rb,
lib/rabbitmq/ffi/gen/basic_publish.rb,
lib/rabbitmq/ffi/gen/basic_recover.rb,
lib/rabbitmq/ffi/gen/channel_close.rb,
lib/rabbitmq/ffi/gen/exchange_bind.rb,
lib/rabbitmq/ffi/gen/queue_bind_ok.rb,
lib/rabbitmq/ffi/gen/queue_declare.rb,
lib/rabbitmq/ffi/gen/access_request.rb,
lib/rabbitmq/ffi/gen/confirm_select.rb,
lib/rabbitmq/ffi/gen/queue_purge_ok.rb,
lib/rabbitmq/ffi/gen/tx_rollback_ok.rb,
lib/rabbitmq/ffi/ext/connection_info.rb,
lib/rabbitmq/ffi/gen/basic_cancel_ok.rb,
lib/rabbitmq/ffi/gen/basic_get_empty.rb,
lib/rabbitmq/ffi/gen/channel_flow_ok.rb,
lib/rabbitmq/ffi/gen/channel_open_ok.rb,
lib/rabbitmq/ffi/gen/connection_open.rb,
lib/rabbitmq/ffi/gen/connection_tune.rb,
lib/rabbitmq/ffi/gen/exchange_delete.rb,
lib/rabbitmq/ffi/gen/exchange_unbind.rb,
lib/rabbitmq/ffi/gen/queue_delete_ok.rb,
lib/rabbitmq/ffi/gen/queue_unbind_ok.rb,
lib/rabbitmq/ffi/ext/basic_properties.rb,
lib/rabbitmq/ffi/gen/basic_consume_ok.rb,
lib/rabbitmq/ffi/gen/basic_recover_ok.rb,
lib/rabbitmq/ffi/gen/channel_close_ok.rb,
lib/rabbitmq/ffi/gen/connection_close.rb,
lib/rabbitmq/ffi/gen/connection_start.rb,
lib/rabbitmq/ffi/gen/exchange_bind_ok.rb,
lib/rabbitmq/ffi/gen/exchange_declare.rb,
lib/rabbitmq/ffi/gen/queue_declare_ok.rb,
lib/rabbitmq/ffi/gen/access_request_ok.rb,
lib/rabbitmq/ffi/gen/confirm_select_ok.rb,
lib/rabbitmq/ffi/gen/connection_secure.rb,
lib/rabbitmq/ffi/gen/connection_blocked.rb,
lib/rabbitmq/ffi/gen/connection_open_ok.rb,
lib/rabbitmq/ffi/gen/connection_tune_ok.rb,
lib/rabbitmq/ffi/gen/exchange_delete_ok.rb,
lib/rabbitmq/ffi/gen/exchange_unbind_ok.rb,
lib/rabbitmq/ffi/gen/basic_recover_async.rb,
lib/rabbitmq/ffi/gen/connection_close_ok.rb,
lib/rabbitmq/ffi/gen/connection_start_ok.rb,
lib/rabbitmq/ffi/gen/exchange_declare_ok.rb,
lib/rabbitmq/ffi/gen/connection_secure_ok.rb,
lib/rabbitmq/ffi/gen/connection_unblocked.rb,
lib/rabbitmq/ffi/ext/frame_payload_properties.rb

Defined Under Namespace

Modules: FFI, Util Classes: Channel, Client, ServerError

Constant Summary collapse

DEFAULT_EXCHANGE = The RabbitMQ default exchange.

"".freeze

AVAILABILITY_ERRORS = An array of errors that indicate an availabilty issue.

[
  RabbitMQ::ServerError::ConnectionError,
  RabbitMQ::FFI::Error::Timeout,
  RabbitMQ::FFI::Error::ConnectionClosed,
  RabbitMQ::FFI::Error::SocketError,
  RabbitMQ::FFI::Error::BadAmqpData,
].freeze