Module: RabbitMQ::FFI Private

Extended by:: FFI::Library

Defined in:: lib/rabbitmq/ffi.rb,
lib/rabbitmq/ffi/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/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

Overview

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

Bindings and wrappers for the native functions and structures exposed by the librabbitmq C library. This module is for internal use only so that all dependencies on the implementation of the C library are abstracted.

Defined Under Namespace

Classes: AccessProperties, AccessRequest, AccessRequestOk, Array, BasicAck, BasicCancel, BasicCancelOk, BasicConsume, BasicConsumeOk, BasicDeliver, BasicGet, BasicGetEmpty, BasicGetOk, BasicNack, BasicProperties, BasicPublish, BasicQos, BasicQosOk, BasicRecover, BasicRecoverAsync, BasicRecoverOk, BasicReject, BasicReturn, Boolean, Bytes, ChannelClose, ChannelCloseOk, ChannelFlow, ChannelFlowOk, ChannelOpen, ChannelOpenOk, ChannelProperties, ConfirmSelect, ConfirmSelectOk, ConnectionBlocked, ConnectionClose, ConnectionCloseOk, ConnectionInfo, ConnectionOpen, ConnectionOpenOk, ConnectionProperties, ConnectionSecure, ConnectionSecureOk, ConnectionStart, ConnectionStartOk, ConnectionTune, ConnectionTuneOk, ConnectionUnblocked, Decimal, Envelope, Error, ExchangeBind, ExchangeBindOk, ExchangeDeclare, ExchangeDeclareOk, ExchangeDelete, ExchangeDeleteOk, ExchangeProperties, ExchangeUnbind, ExchangeUnbindOk, FieldValue, FieldValueValue, Frame, FramePayload, FramePayloadProperties, FramePayloadProtocolHeader, Message, Method, Pool, PoolBlocklist, QueueBind, QueueBindOk, QueueDeclare, QueueDeclareOk, QueueDelete, QueueDeleteOk, QueueProperties, QueuePurge, QueuePurgeOk, QueueUnbind, QueueUnbindOk, RpcReply, Table, TableEntry, Timeval, TxCommit, TxCommitOk, TxProperties, TxRollback, TxRollbackOk, TxSelect, TxSelectOk

Constant Summary collapse

Status =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

enum ::FFI::TypeDefs[:int], [
  :ok,                          0x0,
  :no_memory,                  -0x0001,
  :bad_amqp_data,              -0x0002,
  :unknown_class,              -0x0003,
  :unknown_method,             -0x0004,
  :hostname_resolution_failed, -0x0005,
  :incompatible_amqp_version,  -0x0006,
  :connection_closed,          -0x0007,
  :bad_url,                    -0x0008,
  :socket_error,               -0x0009,
  :invalid_parameter,          -0x000A,
  :table_too_big,              -0x000B,
  :wrong_method,               -0x000C,
  :timeout,                    -0x000D,
  :timer_failure,              -0x000E,
  :heartbeat_timeout,          -0x000F,
  :unexpected_state,           -0x0010,
  :unexpected_socket_closed,   -0x0011,
  :unexpected_socket_inuse,    -0x0012,
  :tcp_error,                  -0x0100,
  :tcp_socketlib_init_error,   -0x0101,
  :ssl_error,                  -0x0200,
  :ssl_hostname_verify_failed, -0x0201,
  :ssl_peer_verify_failed,     -0x0202,
  :ssl_connection_failed,      -0x0203,
]

DeliveryMode =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

enum ::FFI::TypeDefs[:uint8], [
  :nonpersistent, 1,
  :persistent,    2,
]

MethodNumber =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

enum ::FFI::TypeDefs[:uint32], [
  :connection_start,     0x000A000A, # 10, 10; 655370
  :connection_start_ok,  0x000A000B, # 10, 11; 655371
  :connection_secure,    0x000A0014, # 10, 20; 655380
  :connection_secure_ok, 0x000A0015, # 10, 21; 655381
  :connection_tune,      0x000A001E, # 10, 30; 655390
  :connection_tune_ok,   0x000A001F, # 10, 31; 655391
  :connection_open,      0x000A0028, # 10, 40; 655400
  :connection_open_ok,   0x000A0029, # 10, 41; 655401
  :connection_close,     0x000A0032, # 10, 50; 655410
  :connection_close_ok,  0x000A0033, # 10, 51; 655411
  :connection_blocked,   0x000A003C, # 10, 60; 655420
  :connection_unblocked, 0x000A003D, # 10, 61; 655421
  :channel_open,         0x0014000A, # 20, 10; 1310730
  :channel_open_ok,      0x0014000B, # 20, 11; 1310731
  :channel_flow,         0x00140014, # 20, 20; 1310740
  :channel_flow_ok,      0x00140015, # 20, 21; 1310741
  :channel_close,        0x00140028, # 20, 40; 1310760
  :channel_close_ok,     0x00140029, # 20, 41; 1310761
  :access_request,       0x001E000A, # 30, 10; 1966090
  :access_request_ok,    0x001E000B, # 30, 11; 1966091
  :exchange_declare,     0x0028000A, # 40, 10; 2621450
  :exchange_declare_ok,  0x0028000B, # 40, 11; 2621451
  :exchange_delete,      0x00280014, # 40, 20; 2621460
  :exchange_delete_ok,   0x00280015, # 40, 21; 2621461
  :exchange_bind,        0x0028001E, # 40, 30; 2621470
  :exchange_bind_ok,     0x0028001F, # 40, 31; 2621471
  :exchange_unbind,      0x00280028, # 40, 40; 2621480
  :exchange_unbind_ok,   0x00280033, # 40, 51; 2621491
  :queue_declare,        0x0032000A, # 50, 10; 3276810
  :queue_declare_ok,     0x0032000B, # 50, 11; 3276811
  :queue_bind,           0x00320014, # 50, 20; 3276820
  :queue_bind_ok,        0x00320015, # 50, 21; 3276821
  :queue_purge,          0x0032001E, # 50, 30; 3276830
  :queue_purge_ok,       0x0032001F, # 50, 31; 3276831
  :queue_delete,         0x00320028, # 50, 40; 3276840
  :queue_delete_ok,      0x00320029, # 50, 41; 3276841
  :queue_unbind,         0x00320032, # 50, 50; 3276850
  :queue_unbind_ok,      0x00320033, # 50, 51; 3276851
  :basic_qos,            0x003C000A, # 60, 10; 3932170
  :basic_qos_ok,         0x003C000B, # 60, 11; 3932171
  :basic_consume,        0x003C0014, # 60, 20; 3932180
  :basic_consume_ok,     0x003C0015, # 60, 21; 3932181
  :basic_cancel,         0x003C001E, # 60, 30; 3932190
  :basic_cancel_ok,      0x003C001F, # 60, 31; 3932191
  :basic_publish,        0x003C0028, # 60, 40; 3932200
  :basic_return,         0x003C0032, # 60, 50; 3932210
  :basic_deliver,        0x003C003C, # 60, 60; 3932220
  :basic_get,            0x003C0046, # 60, 70; 3932230
  :basic_get_ok,         0x003C0047, # 60, 71; 3932231
  :basic_get_empty,      0x003C0048, # 60, 72; 3932232
  :basic_ack,            0x003C0050, # 60, 80; 3932240
  :basic_reject,         0x003C005A, # 60, 90; 3932250
  :basic_recover_async,  0x003C0064, # 60, 100; 3932260
  :basic_recover,        0x003C006E, # 60, 110; 3932270
  :basic_recover_ok,     0x003C006F, # 60, 111; 3932271
  :basic_nack,           0x003C0078, # 60, 120; 3932280
  :tx_select,            0x005A000A, # 90, 10; 5898250
  :tx_select_ok,         0x005A000B, # 90, 11; 5898251
  :tx_commit,            0x005A0014, # 90, 20; 5898260
  :tx_commit_ok,         0x005A0015, # 90, 21; 5898261
  :tx_rollback,          0x005A001E, # 90, 30; 5898270
  :tx_rollback_ok,       0x005A001F, # 90, 31; 5898271
  :confirm_select,       0x0055000A, # 85, 10; 5570570
  :confirm_select_ok,    0x0055000B, # 85, 11; 5570571
]

Flags =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

:uint32

Channel =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

CHANNEL_MAX_ID =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

2 ** (Channel.size * 8) - 1

FieldValueKind =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

enum ::FFI::TypeDefs[:uint8], [
  :boolean,   't'.ord,
  :i8,        'b'.ord,
  :u8,        'B'.ord,
  :i16,       's'.ord,
  :u16,       'u'.ord,
  :i32,       'I'.ord,
  :u32,       'i'.ord,
  :i64,       'l'.ord,
  :u64,       'L'.ord,
  :f32,       'f'.ord,
  :f64,       'd'.ord,
  :decimal,   'D'.ord,
  :utf8,      'S'.ord,
  :array,     'A'.ord,
  :timestamp, 'T'.ord,
  :table,     'F'.ord,
  :void,      'V'.ord,
  :bytes,     'x'.ord,
]

FrameType =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

enum ::FFI::TypeDefs[:uint8], [
  :method,    1,
  :header,    2,
  :body,      3,
  :heartbeat, 8,
]

ResponseType =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

enum [
  :none, 0,
  :normal,
  :library_exception,
  :server_exception,
]

SaslMethod =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

enum [
  :plain, 0,
]

ConnectionState =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

:pointer

Class Method Summary collapse

.has_ssl? ⇒ Boolean private

Class Method Details

.has_ssl? ⇒ `Boolean`

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns:

(Boolean)

505	# File 'lib/rabbitmq/ffi.rb', line 505 def self.has_ssl?; @has_ssl; end