Public API

Structures

amqp_access_properties_taccess class properties
amqp_access_request_ok_taccess.request-ok method fields
amqp_access_request_taccess.request method fields
amqp_array_tAn AMQP Field Array
amqp_basic_ack_tbasic.ack method fields
amqp_basic_cancel_ok_tbasic.cancel-ok method fields
amqp_basic_cancel_tbasic.cancel method fields
amqp_basic_consume_ok_tbasic.consume-ok method fields
amqp_basic_consume_tbasic.consume method fields
amqp_basic_deliver_tbasic.deliver method fields
amqp_basic_get_empty_tbasic.get-empty method fields
amqp_basic_get_ok_tbasic.get-ok method fields
amqp_basic_get_tbasic.get method fields
amqp_basic_nack_tbasic.nack method fields
amqp_basic_properties_tbasic class properties
amqp_basic_publish_tbasic.publish method fields
amqp_basic_qos_ok_tbasic.qos-ok method fields
amqp_basic_qos_tbasic.qos method fields
amqp_basic_recover_async_tbasic.recover-async method fields
amqp_basic_recover_ok_tbasic.recover-ok method fields
amqp_basic_recover_tbasic.recover method fields
amqp_basic_reject_tbasic.reject method fields
amqp_basic_return_tbasic.return method fields
amqp_bytes_tBuffer descriptor
amqp_channel_close_ok_tchannel.close-ok method fields
amqp_channel_close_tchannel.close method fields
amqp_channel_flow_ok_tchannel.flow-ok method fields
amqp_channel_flow_tchannel.flow method fields
amqp_channel_open_ok_tchannel.open-ok method fields
amqp_channel_open_tchannel.open method fields
amqp_channel_properties_tchannel class properties
amqp_confirm_properties_tconfirm class properties
amqp_confirm_select_ok_tconfirm.select-ok method fields
amqp_confirm_select_tconfirm.select method fields
amqp_connection_blocked_tconnection.blocked method fields
amqp_connection_close_ok_tconnection.close-ok method fields
amqp_connection_close_tconnection.close method fields
amqp_connection_infoParameters used to connect to the RabbitMQ broker
amqp_connection_open_ok_tconnection.open-ok method fields
amqp_connection_open_tconnection.open method fields
amqp_connection_properties_tconnection class properties
amqp_connection_secure_ok_tconnection.secure-ok method fields
amqp_connection_secure_tconnection.secure method fields
amqp_connection_start_ok_tconnection.start-ok method fields
amqp_connection_start_tconnection.start method fields
amqp_connection_state_t_connection state object
amqp_connection_tune_ok_tconnection.tune-ok method fields
amqp_connection_tune_tconnection.tune method fields
amqp_connection_unblocked_tconnection.unblocked method fields
amqp_decimal_tDecimal data type
amqp_envelope_tEnvelope object
amqp_exchange_bind_ok_texchange.bind-ok method fields
amqp_exchange_bind_texchange.bind method fields
amqp_exchange_declare_ok_texchange.declare-ok method fields
amqp_exchange_declare_texchange.declare method fields
amqp_exchange_delete_ok_texchange.delete-ok method fields
amqp_exchange_delete_texchange.delete method fields
amqp_exchange_properties_texchange class properties
amqp_exchange_unbind_ok_texchange.unbind-ok method fields
amqp_exchange_unbind_texchange.unbind method fields
amqp_field_value_tA field table value
amqp_frame_tAn AMQP frame
amqp_link_t
amqp_message_tA message object
amqp_method_tAn amqp method
amqp_pool_blocklist_tA list of allocation blocks
amqp_pool_tA memory pool
amqp_pool_table_entry_t
amqp_queue_bind_ok_tqueue.bind-ok method fields
amqp_queue_bind_tqueue.bind method fields
amqp_queue_declare_ok_tqueue.declare-ok method fields
amqp_queue_declare_tqueue.declare method fields
amqp_queue_delete_ok_tqueue.delete-ok method fields
amqp_queue_delete_tqueue.delete method fields
amqp_queue_properties_tqueue class properties
amqp_queue_purge_ok_tqueue.purge-ok method fields
amqp_queue_purge_tqueue.purge method fields
amqp_queue_unbind_ok_tqueue.unbind-ok method fields
amqp_queue_unbind_tqueue.unbind method fields
amqp_rpc_reply_tReply from a RPC method on the broker
amqp_socket_class_tV-table for amqp_socket_t
amqp_socket_t_Abstract base class for amqp_socket_t
amqp_ssl_socket_t
amqp_table_entry_tAn entry in a field-table
amqp_table_tAMQP field table
amqp_tcp_socket_t
amqp_time_t
amqp_tx_commit_ok_ttx.commit-ok method fields
amqp_tx_commit_ttx.commit method fields
amqp_tx_properties_ttx class properties
amqp_tx_rollback_ok_ttx.rollback-ok method fields
amqp_tx_rollback_ttx.rollback method fields
amqp_tx_select_ok_ttx.select-ok method fields
amqp_tx_select_ttx.select method fields

Functions

amqp_abort
amqp_basic_ackAcknowledges a message
amqp_basic_cancelamqp_basic_cancel
amqp_basic_consumeamqp_basic_consume
amqp_basic_getDo a basic.get
amqp_basic_nackDo a basic.nack
amqp_basic_publishPublish a message to the broker
amqp_basic_qosamqp_basic_qos
amqp_basic_recoveramqp_basic_recover
amqp_basic_rejectDo a basic.reject
amqp_bytes_equal
amqp_bytes_freeFrees an amqp_bytes_t buffer
amqp_bytes_mallocAllocates a amqp_bytes_t buffer
amqp_bytes_malloc_dupDuplicates an amqp_bytes_t buffer.
amqp_channel_closeCloses an channel
amqp_channel_flowamqp_channel_flow
amqp_channel_openamqp_channel_open
amqp_confirm_selectamqp_confirm_select
amqp_connection_closeCloses the entire connection
amqp_constant_is_hard_errorChecks to see if a constant is a hard error
amqp_constant_nameGet constant name string from constant
amqp_consume_messageWait for and consume a message
amqp_cstring_bytesWraps a c string in an amqp_bytes_t
amqp_data_in_bufferCheck to see if there is data left in the receive buffer
amqp_decode_methodDecodes a method from AMQP wireformat
amqp_decode_propertiesDecodes a header frame properties structure from AMQP wireformat
amqp_decode_tableDeserialize an amqp_table_t from AMQP wireformat
amqp_default_connection_infoInitialze an amqp_connection_info to default values
amqp_destroy_connectionDestroys an amqp_connection_state_t object
amqp_destroy_envelopeFrees memory associated with a amqp_envelope_t allocated in amqp_consume_message()
amqp_destroy_messageFrees memory associated with a amqp_message_t allocated in amqp_read_message
amqp_encode_methodEncodes a method structure in AMQP wireformat
amqp_encode_propertiesEncodes a properties structure in AMQP wireformat
amqp_encode_tableSerializes an amqp_table_t to the AMQP wireformat
amqp_error_stringGet the error string for the given error code.
amqp_error_string2Get the error string for the given error code.
amqp_exchange_bindamqp_exchange_bind
amqp_exchange_declareamqp_exchange_declare
amqp_exchange_deleteamqp_exchange_delete
amqp_exchange_unbindamqp_exchange_unbind
amqp_frames_enqueuedChecks to see if there are any incoming frames ready to be read
amqp_get_channel_maxGet the maximum number of channels the connection can handle
amqp_get_channel_pool
amqp_get_client_propertiesGet the client properties table
amqp_get_frame_maxGet the maximum size of an frame the connection can handle
amqp_get_handshake_timeoutGet the login handshake timeout.
amqp_get_heartbeatGet the number of seconds between heartbeats of the connection
amqp_get_monotonic_timestamp
amqp_get_or_create_channel_pool
amqp_get_rpc_replyGet the last global amqp_rpc_reply
amqp_get_rpc_timeoutGet the RPC timeout
amqp_get_server_propertiesGet the broker properties table
amqp_get_socketGet the socket object associated with a amqp_connection_state_t
amqp_get_sockfdGet the underlying socket descriptor for the connection
amqp_handle_inputProcess incoming data
amqp_hostcheckDetermine whether hostname matches match_pattern.
amqp_initialize_ssl_libraryInitialize the underlying SSL/TLS library.
amqp_loginLogin to the broker
amqp_login_with_propertiesLogin to the broker passing a properties table
amqp_maybe_release_buffersRelease amqp_connection_state_t owned memory
amqp_maybe_release_buffers_on_channelRelease amqp_connection_state_t owned memory related to a channel
amqp_merge_capabilities
amqp_method_has_contentCheck whether a method has content
amqp_method_nameGet method name string from method number
amqp_new_connectionAllocate and initialize a new amqp_connection_state_t object
amqp_open_socketOpen a socket to a remote host
amqp_open_socket_inner
amqp_open_socket_noblockOpen a socket connection.
amqp_openssl_bio
amqp_openssl_bio_destroy
amqp_openssl_bio_init
amqp_os_error_string
amqp_os_socket_close
amqp_os_socket_error
amqp_parse_urlParse a connection URL
amqp_poll
amqp_pool_allocAllocates a block of memory from an amqp_pool_t memory pool
amqp_pool_alloc_bytesAllocates a block of memory from an amqp_pool_t to an amqp_bytes_t
amqp_put_back_frame
amqp_queue_bindamqp_queue_bind
amqp_queue_declareamqp_queue_declare
amqp_queue_deleteamqp_queue_delete
amqp_queue_frame
amqp_queue_purgeamqp_queue_purge
amqp_queue_unbindamqp_queue_unbind
amqp_read_messageReads the next message on a channel
amqp_release_buffersRelease amqp_connection_state_t owned memory
amqp_release_buffers_okCheck to see if connection memory can be released
amqp_send_frameSend a frame to the broker
amqp_send_frame_inner
amqp_send_headerSend initial AMQP header to the broker
amqp_send_methodSends a method to the broker
amqp_send_method_inner
amqp_set_handshake_timeoutSet the login handshake timeout.
amqp_set_initialize_ssl_librarySets whether rabbitmq-c will initialize OpenSSL.
amqp_set_rpc_timeoutSet the RPC timeout
amqp_set_socketSet set the socket object for a connection
amqp_set_sockfdDeprecated, use amqp_tcp_socket_new() or amqp_ssl_socket_new()
amqp_set_ssl_engineSet the engine for underlying SSL/TLS library.
amqp_simple_rpcSends a method to the broker and waits for a method response
amqp_simple_rpc_decodedSends a method to the broker and waits for a method response
amqp_simple_wait_frameRead a single amqp_frame_t
amqp_simple_wait_frame_noblockRead a single amqp_frame_t with a timeout.
amqp_simple_wait_frame_on_channel
amqp_simple_wait_methodWaits for a specific method from the broker
amqp_socket_closeClose a socket connection and free resources.
amqp_socket_deleteDestroy a socket object
amqp_socket_get_sockfdGet the socket descriptor in use by a socket object.
amqp_socket_openOpen a socket connection.
amqp_socket_open_noblockOpen a socket connection.
amqp_socket_recvReceive a message from a socket.
amqp_socket_sendSend a message from a socket.
amqp_ssl_socket_get_contextGet the internal OpenSSL context
amqp_ssl_socket_newCreate a new SSL/TLS socket object.
amqp_ssl_socket_set_cacertSet the CA certificate.
amqp_ssl_socket_set_cert
amqp_ssl_socket_set_keySet the client key.
amqp_ssl_socket_set_key_bufferSet the client key from a buffer.
amqp_ssl_socket_set_key_engineSet the client key use the engine.
amqp_ssl_socket_set_ssl_versionsSet min and max TLS versions.
amqp_ssl_socket_set_verifyEnable or disable peer verification.
amqp_ssl_socket_set_verify_hostnameEnable or disable hostname verification.
amqp_ssl_socket_set_verify_peerEnable or disable peer verification.
amqp_ssl_validate_hostnameValidates the server's identity by looking for the expected hostname in the server's certificate
amqp_table_cloneCreate a deep-copy of an amqp_table_t object
amqp_table_construct_bool_entryInitializes a table entry with boolean type value.
amqp_table_construct_table_entryInitializes a table entry with table type value.
amqp_table_construct_utf8_entryInitializes a table entry with utf-8 string type value.
amqp_table_entry_cmpCompare two table entries
amqp_table_get_entry_by_keySearches a table for an entry with a matching key.
amqp_tcp_socket_newA TCP socket connection
amqp_tcp_socket_set_sockfdAssign an open file descriptor to a socket object.
amqp_time_equal
amqp_time_first
amqp_time_from_now
amqp_time_has_past
amqp_time_infinite
amqp_time_ms_until
amqp_time_s_from_now
amqp_time_tv_until
amqp_try_recv
amqp_try_send
amqp_tune_connectionTune client side parameters
amqp_tx_commitamqp_tx_commit
amqp_tx_rollbackamqp_tx_rollback
amqp_tx_selectamqp_tx_select
amqp_uninitialize_ssl_libraryUninitialize the underlying SSL/TLS library.
amqp_versionReturns the rabbitmq-c version as a string.
amqp_version_numberReturns the rabbitmq-c version as a packed integer.
empty_amqp_poolEmpties an amqp memory pool
init_amqp_poolInitializes an amqp_pool_t memory allocation pool for use
pthread_mutex_destroy
pthread_mutex_init
pthread_mutex_lock
pthread_mutex_unlock
pthread_self
recycle_amqp_poolRecycles an amqp_pool_t memory allocation pool
sasl_mechanism_in_list

Enums

amqp_field_value_kind_tField value types
amqp_response_type_enumResponse type
amqp_sasl_method_enumSASL method type
amqp_status_enumStatus codes
amqp_delivery_mode_enumAMQP delivery modes
error_category_enum_
amqp_hostcheck_result
amqp_hostname_validation_result
amqp_connection_state_enum
amqp_status_private_enum
amqp_socket_flag_enumAn abstract socket interface.
amqp_socket_close_enum
amqp_tls_version_t

Defines

Defines (amqp.h)

AMQP_VERSION_MAJOR 0

Major library version number compile-time constant

The major version is incremented when backwards incompatible API changes are made.

See
AMQP_VERSION, AMQP_VERSION_STRING
Since
v0.4.0

AMQP_VERSION_MINOR 11

Minor library version number compile-time constant

The minor version is incremented when new APIs are added. Existing APIs are left alone.

See
AMQP_VERSION, AMQP_VERSION_STRING
Since
v0.4.0

AMQP_VERSION_PATCH 0

Patch library version number compile-time constant

The patch version is incremented when library code changes, but the API is not changed.

See
AMQP_VERSION, AMQP_VERSION_STRING
Since
v0.4.0

AMQP_VERSION_IS_RELEASE 0

Version constant set to 1 for tagged release, 0 otherwise

NOTE: versions that are not tagged releases are not guaranteed to be API/ABI compatible with older releases, and may change commit-to-commit.

See
AMQP_VERSION, AMQP_VERSION_STRING
Since
v0.4.0

AMQP_VERSION_CODE(major,minor,patch,release)
((major << 24) | (minor << 16) | (patch << 8) | (release))

Helper macro to geneate a packed version code suitable for comparison with AMQP_VERSION.

See
amqp_version_number() AMQP_VERSION_MAJOR, AMQP_VERSION_MINOR, AMQP_VERSION_PATCH, AMQP_VERSION_IS_RELEASE, AMQP_VERSION
Since
v0.6.1

AMQP_VERSION AMQP_VERSION_CODE(AMQP_VERSION_MAJOR, AMQP_VERSION_MINOR,
AMQP_VERSION_PATCH, AMQP_VERSION_IS_RELEASE)

Packed version number

AMQP_VERSION is a 4-byte unsigned integer with the most significant byte set to AMQP_VERSION_MAJOR, the second most significant byte set to AMQP_VERSION_MINOR, third most significant byte set to AMQP_VERSION_PATCH, and the lowest byte set to AMQP_VERSION_IS_RELEASE.

For example version 2.3.4 which is released version would be encoded as 0x02030401

See
amqp_version_number() AMQP_VERSION_MAJOR, AMQP_VERSION_MINOR, AMQP_VERSION_PATCH, AMQP_VERSION_IS_RELEASE, AMQP_VERSION_CODE
Since
v0.4.0

AMQP_VERSION_STRING AMQ_VERSION_STRING "-pre"

Version string compile-time constant

Non-released versions of the library will have "-pre" appended to the version string

See
amqp_version()
Since
v0.4.0

AMQP_DEFAULT_FRAME_SIZE 131072

Default frame size (128Kb)

See
amqp_login(), amqp_login_with_properties()
Since
v0.4.0

AMQP_DEFAULT_MAX_CHANNELS 2047

Default maximum number of channels (2047, RabbitMQ default limit of 2048, minus 1 for channel 0). RabbitMQ set a default limit of 2048 channels per connection in v3.7.5 to prevent broken clients from leaking too many channels.

See
amqp_login(), amqp_login_with_properties()
Since
v0.4.0

AMQP_DEFAULT_HEARTBEAT 0

Default heartbeat interval (0, heartbeat disabled)

See
amqp_login(), amqp_login_with_properties()
Since
v0.4.0

AMQP_DEFAULT_VHOST "/"

Default RabbitMQ vhost: "/"

See
amqp_login(), amqp_login_with_properties()
Since
v0.9.0

AMQP_EMPTY_BYTES amqp_empty_bytes

Deprecated, use amqp_empty_bytes instead

Deprecated
use amqp_empty_bytes instead
Since
v0.1

AMQP_EMPTY_TABLE amqp_empty_table

Deprecated, use amqp_empty_table instead

Deprecated
use amqp_empty_table instead
Since
v0.1

AMQP_EMPTY_ARRAY amqp_empty_array

Deprecated, use amqp_empty_array instead

Deprecated
use amqp_empty_array instead
Since
v0.1

Defines (amqp_api.c)

ERROR_MASK (0x00FF)

ERROR_CATEGORY_MASK (0xFF00)

Defines (amqp_connection.c)

AMQP_INITIAL_FRAME_POOL_PAGE_SIZE 65536

AMQP_INITIAL_INBOUND_SOCK_BUFFER_SIZE 131072

AMQP_DEFAULT_LOGIN_TIMEOUT_SEC 12

ENFORCE_STATE(statevec,statenum)
{
amqp_connection_state_t _check_state = (statevec);
amqp_connection_state_enum _wanted_state = (statenum);
if (_check_state->state != _wanted_state)
amqp_abort(
"Programming error: invalid AMQP connection state: expected %d, "
"got %d",
_wanted_state, _check_state->state);
}

Defines (amqp_consumer.c)

CLONE_BYTES_POOL(original,clone,pool)
if (0 == original.len) {
clone = amqp_empty_bytes;
} else {
amqp_pool_alloc_bytes(pool, original.len, &clone);
if (NULL == clone.bytes) {
return AMQP_STATUS_NO_MEMORY;
}
memcpy(clone.bytes, original.bytes, clone.len);
}

Defines (amqp_framing.h)

AMQP_PROTOCOL_VERSION_MAJOR 0

AMQP protocol version major

AMQP_PROTOCOL_VERSION_MINOR 9

AMQP protocol version minor

AMQP_PROTOCOL_VERSION_REVISION 1

AMQP protocol version revision

AMQP_PROTOCOL_PORT 5672

Default AMQP Port

AMQP_FRAME_METHOD 1

Constant: FRAME-METHOD

Mentioned in

Examples / amqp_consumer.c

Examples / amqp_rpc_sendstring_client.c

AMQP_FRAME_HEADER 2

Constant: FRAME-HEADER

Mentioned in

Examples / amqp_rpc_sendstring_client.c

AMQP_FRAME_BODY 3

Constant: FRAME-BODY

Mentioned in

Examples / amqp_rpc_sendstring_client.c

AMQP_FRAME_HEARTBEAT 8

Constant: FRAME-HEARTBEAT

AMQP_FRAME_MIN_SIZE 4096

Constant: FRAME-MIN-SIZE

AMQP_FRAME_END 206

Constant: FRAME-END

AMQP_REPLY_SUCCESS 200

Constant: REPLY-SUCCESS

Mentioned in

Examples / amqp_bind.c

Examples / amqp_connect_timeout.c

Examples / amqp_consumer.c

Examples / amqp_exchange_declare.c

Examples / amqp_listen.c

Examples / amqp_listenq.c

Examples / amqp_producer.c

Examples / amqp_rpc_sendstring_client.c

Examples / amqp_sendstring.c

Examples / amqp_ssl_connect.c

Examples / amqp_unbind.c

AMQP_CONTENT_TOO_LARGE 311

Constant: CONTENT-TOO-LARGE

AMQP_NO_ROUTE 312

Constant: NO-ROUTE

AMQP_NO_CONSUMERS 313

Constant: NO-CONSUMERS

AMQP_ACCESS_REFUSED 403

Constant: ACCESS-REFUSED

AMQP_NOT_FOUND 404

Constant: NOT-FOUND

AMQP_RESOURCE_LOCKED 405

Constant: RESOURCE-LOCKED

AMQP_PRECONDITION_FAILED 406

Constant: PRECONDITION-FAILED

AMQP_CONNECTION_FORCED 320

Constant: CONNECTION-FORCED

AMQP_INVALID_PATH 402

Constant: INVALID-PATH

AMQP_FRAME_ERROR 501

Constant: FRAME-ERROR

AMQP_SYNTAX_ERROR 502

Constant: SYNTAX-ERROR

AMQP_COMMAND_INVALID 503

Constant: COMMAND-INVALID

AMQP_CHANNEL_ERROR 504

Constant: CHANNEL-ERROR

AMQP_UNEXPECTED_FRAME 505

Constant: UNEXPECTED-FRAME

AMQP_RESOURCE_ERROR 506

Constant: RESOURCE-ERROR

AMQP_NOT_ALLOWED 530

Constant: NOT-ALLOWED

AMQP_NOT_IMPLEMENTED 540

Constant: NOT-IMPLEMENTED

AMQP_INTERNAL_ERROR 541

Constant: INTERNAL-ERROR

AMQP_CONNECTION_START_METHOD ((amqp_method_number_t)0x000A000A)

connection.start method id

AMQP_CONNECTION_START_OK_METHOD ((amqp_method_number_t)0x000A000B)

connection.start-ok method id

AMQP_CONNECTION_SECURE_METHOD ((amqp_method_number_t)0x000A0014)

connection.secure method id

AMQP_CONNECTION_SECURE_OK_METHOD ((amqp_method_number_t)0x000A0015)

connection.secure-ok method id

AMQP_CONNECTION_TUNE_METHOD ((amqp_method_number_t)0x000A001E)

connection.tune method id

AMQP_CONNECTION_TUNE_OK_METHOD ((amqp_method_number_t)0x000A001F)

connection.tune-ok method id

AMQP_CONNECTION_OPEN_METHOD ((amqp_method_number_t)0x000A0028)

connection.open method id

AMQP_CONNECTION_OPEN_OK_METHOD ((amqp_method_number_t)0x000A0029)

connection.open-ok method id

AMQP_CONNECTION_CLOSE_METHOD ((amqp_method_number_t)0x000A0032)

connection.close method id

Mentioned in

Examples / amqp_consumer.c

Examples / utils.c

AMQP_CONNECTION_CLOSE_OK_METHOD ((amqp_method_number_t)0x000A0033)

connection.close-ok method id

AMQP_CONNECTION_BLOCKED_METHOD ((amqp_method_number_t)0x000A003C)

connection.blocked method id

AMQP_CONNECTION_UNBLOCKED_METHOD ((amqp_method_number_t)0x000A003D)

connection.unblocked method id

AMQP_CHANNEL_OPEN_METHOD ((amqp_method_number_t)0x0014000A)

channel.open method id

AMQP_CHANNEL_OPEN_OK_METHOD ((amqp_method_number_t)0x0014000B)

channel.open-ok method id

AMQP_CHANNEL_FLOW_METHOD ((amqp_method_number_t)0x00140014)

channel.flow method id

AMQP_CHANNEL_FLOW_OK_METHOD ((amqp_method_number_t)0x00140015)

channel.flow-ok method id

AMQP_CHANNEL_CLOSE_METHOD ((amqp_method_number_t)0x00140028)

channel.close method id

Mentioned in

Examples / amqp_consumer.c

Examples / utils.c

AMQP_CHANNEL_CLOSE_OK_METHOD ((amqp_method_number_t)0x00140029)

channel.close-ok method id

AMQP_ACCESS_REQUEST_METHOD ((amqp_method_number_t)0x001E000A)

access.request method id

AMQP_ACCESS_REQUEST_OK_METHOD ((amqp_method_number_t)0x001E000B)

access.request-ok method id

AMQP_EXCHANGE_DECLARE_METHOD ((amqp_method_number_t)0x0028000A)

exchange.declare method id

AMQP_EXCHANGE_DECLARE_OK_METHOD ((amqp_method_number_t)0x0028000B)

exchange.declare-ok method id

AMQP_EXCHANGE_DELETE_METHOD ((amqp_method_number_t)0x00280014)

exchange.delete method id

AMQP_EXCHANGE_DELETE_OK_METHOD ((amqp_method_number_t)0x00280015)

exchange.delete-ok method id

AMQP_EXCHANGE_BIND_METHOD ((amqp_method_number_t)0x0028001E)

exchange.bind method id

AMQP_EXCHANGE_BIND_OK_METHOD ((amqp_method_number_t)0x0028001F)

exchange.bind-ok method id

AMQP_EXCHANGE_UNBIND_METHOD ((amqp_method_number_t)0x00280028)

exchange.unbind method id

AMQP_EXCHANGE_UNBIND_OK_METHOD ((amqp_method_number_t)0x00280033)

exchange.unbind-ok method id

AMQP_QUEUE_DECLARE_METHOD ((amqp_method_number_t)0x0032000A)

queue.declare method id

AMQP_QUEUE_DECLARE_OK_METHOD ((amqp_method_number_t)0x0032000B)

queue.declare-ok method id

AMQP_QUEUE_BIND_METHOD ((amqp_method_number_t)0x00320014)

queue.bind method id

AMQP_QUEUE_BIND_OK_METHOD ((amqp_method_number_t)0x00320015)

queue.bind-ok method id

AMQP_QUEUE_PURGE_METHOD ((amqp_method_number_t)0x0032001E)

queue.purge method id

AMQP_QUEUE_PURGE_OK_METHOD ((amqp_method_number_t)0x0032001F)

queue.purge-ok method id

AMQP_QUEUE_DELETE_METHOD ((amqp_method_number_t)0x00320028)

queue.delete method id

AMQP_QUEUE_DELETE_OK_METHOD ((amqp_method_number_t)0x00320029)

queue.delete-ok method id

AMQP_QUEUE_UNBIND_METHOD ((amqp_method_number_t)0x00320032)

queue.unbind method id

AMQP_QUEUE_UNBIND_OK_METHOD ((amqp_method_number_t)0x00320033)

queue.unbind-ok method id

AMQP_BASIC_QOS_METHOD ((amqp_method_number_t)0x003C000A)

basic.qos method id

AMQP_BASIC_QOS_OK_METHOD ((amqp_method_number_t)0x003C000B)

basic.qos-ok method id

AMQP_BASIC_CONSUME_METHOD ((amqp_method_number_t)0x003C0014)

basic.consume method id

AMQP_BASIC_CONSUME_OK_METHOD ((amqp_method_number_t)0x003C0015)

basic.consume-ok method id

AMQP_BASIC_CANCEL_METHOD ((amqp_method_number_t)0x003C001E)

basic.cancel method id

AMQP_BASIC_CANCEL_OK_METHOD ((amqp_method_number_t)0x003C001F)

basic.cancel-ok method id

AMQP_BASIC_PUBLISH_METHOD ((amqp_method_number_t)0x003C0028)

basic.publish method id

AMQP_BASIC_RETURN_METHOD ((amqp_method_number_t)0x003C0032)

basic.return method id

Mentioned in

Examples / amqp_consumer.c

AMQP_BASIC_DELIVER_METHOD ((amqp_method_number_t)0x003C003C)

basic.deliver method id

Mentioned in

Examples / amqp_rpc_sendstring_client.c

AMQP_BASIC_GET_METHOD ((amqp_method_number_t)0x003C0046)

basic.get method id

AMQP_BASIC_GET_OK_METHOD ((amqp_method_number_t)0x003C0047)

basic.get-ok method id

AMQP_BASIC_GET_EMPTY_METHOD ((amqp_method_number_t)0x003C0048)

basic.get-empty method id

AMQP_BASIC_ACK_METHOD ((amqp_method_number_t)0x003C0050)

basic.ack method id

Mentioned in

Examples / amqp_consumer.c

AMQP_BASIC_REJECT_METHOD ((amqp_method_number_t)0x003C005A)

basic.reject method id

AMQP_BASIC_RECOVER_ASYNC_METHOD ((amqp_method_number_t)0x003C0064)

basic.recover-async method id

AMQP_BASIC_RECOVER_METHOD ((amqp_method_number_t)0x003C006E)

basic.recover method id

AMQP_BASIC_RECOVER_OK_METHOD ((amqp_method_number_t)0x003C006F)

basic.recover-ok method id

AMQP_BASIC_NACK_METHOD ((amqp_method_number_t)0x003C0078)

basic.nack method id

AMQP_TX_SELECT_METHOD ((amqp_method_number_t)0x005A000A)

tx.select method id

AMQP_TX_SELECT_OK_METHOD ((amqp_method_number_t)0x005A000B)

tx.select-ok method id

AMQP_TX_COMMIT_METHOD ((amqp_method_number_t)0x005A0014)

tx.commit method id

AMQP_TX_COMMIT_OK_METHOD ((amqp_method_number_t)0x005A0015)

tx.commit-ok method id

AMQP_TX_ROLLBACK_METHOD ((amqp_method_number_t)0x005A001E)

tx.rollback method id

AMQP_TX_ROLLBACK_OK_METHOD ((amqp_method_number_t)0x005A001F)

tx.rollback-ok method id

AMQP_CONFIRM_SELECT_METHOD ((amqp_method_number_t)0x0055000A)

confirm.select method id

AMQP_CONFIRM_SELECT_OK_METHOD ((amqp_method_number_t)0x0055000B)

confirm.select-ok method id

AMQP_CONNECTION_CLASS (0x000A)

connection class id

AMQP_CHANNEL_CLASS (0x0014)

channel class id

AMQP_ACCESS_CLASS (0x001E)

access class id

AMQP_EXCHANGE_CLASS (0x0028)

exchange class id

AMQP_QUEUE_CLASS (0x0032)

queue class id

AMQP_BASIC_CLASS (0x003C)

basic class id

AMQP_BASIC_CONTENT_TYPE_FLAG (1 << 15)

Mentioned in

AMQP_BASIC_CONTENT_ENCODING_FLAG (1 << 14)

AMQP_BASIC_HEADERS_FLAG (1 << 13)

AMQP_BASIC_DELIVERY_MODE_FLAG (1 << 12)

Mentioned in

AMQP_BASIC_PRIORITY_FLAG (1 << 11)

AMQP_BASIC_CORRELATION_ID_FLAG (1 << 10)

Mentioned in

AMQP_BASIC_REPLY_TO_FLAG (1 << 9)

Mentioned in

AMQP_BASIC_EXPIRATION_FLAG (1 << 8)

AMQP_BASIC_MESSAGE_ID_FLAG (1 << 7)

AMQP_BASIC_TIMESTAMP_FLAG (1 << 6)

AMQP_BASIC_TYPE_FLAG (1 << 5)

AMQP_BASIC_USER_ID_FLAG (1 << 4)

AMQP_BASIC_APP_ID_FLAG (1 << 3)

AMQP_BASIC_CLUSTER_ID_FLAG (1 << 2)

AMQP_TX_CLASS (0x005A)

tx class id

AMQP_CONFIRM_CLASS (0x0055)

confirm class id

Defines (amqp_openssl.c)

CHECK_SUCCESS(condition)
do {
int check_success_ret = (condition);
if (check_success_ret) {
amqp_abort("Check %s failed <%d>: %s", #condition, check_success_ret,
strerror(check_success_ret));
}
} while (0)

Defines (amqp_openssl_hostname_validation.c)

HOSTNAME_MAX_SIZE 255

Defines (amqp_private.h)

AMQP_NORETURN

AMQP_UNUSED

AMQP_PRIVATE

HEADER_SIZE 7

AMQP_PSEUDOFRAME_PROTOCOL_HEADER 'A'

POOL_TABLE_SIZE 16

DECLARE_CODEC_BASE_TYPE(bits)

static inline int amqp_encode_##bits(amqp_bytes_t encoded, size_t *offset,
uint##bits##_t input) {
size_t o = *offset;
if ((*offset = o + bits / 8) <= encoded.len) {
amqp_e##bits(input, amqp_offset(encoded.bytes, o));
return 1;
}
return 0;
}

static inline int amqp_decode_##bits(amqp_bytes_t encoded, size_t *offset,
uint##bits##_t *output) {
size_t o = *offset;
if ((*offset = o + bits / 8) <= encoded.len) {
*output = amqp_d##bits(amqp_offset(encoded.bytes, o));
return 1;
}
return 0;
}

Defines (amqp_table.c)

INITIAL_ARRAY_SIZE 16

INITIAL_TABLE_SIZE 16

TRIVIAL_FIELD_DECODER(bits)
if (!amqp_decode_##bits(encoded, offset, &entry->value.u##bits)) goto out;
break

SIMPLE_FIELD_DECODER(bits,dest,how)
{
uint##bits##_t val;
if (!amqp_decode_##bits(encoded, offset, &val)) goto out;
entry->value.dest = how;
}
break

FIELD_ENCODER(bits,val)
if (!amqp_encode_##bits(encoded, offset, val)) {
res = AMQP_STATUS_TABLE_TOO_BIG;
goto out;
}
break

Defines (amqp_time.c)

AMQP_POSIX_TIMER_API

Defines (amqp_time.h)

AMQP_MS_PER_S 1000

AMQP_US_PER_MS 1000

AMQP_NS_PER_S 1000000000

AMQP_NS_PER_MS 1000000

AMQP_NS_PER_US 1000

Defines (threads.h)

WINVER 0x0600

WIN32_LEAN_AND_MEAN

Mentioned in

PTHREAD_MUTEX_INITIALIZER SRWLOCK_INIT;

Defines (stdint.h)

_W64

INT8_MIN ((int8_t)_I8_MIN)

INT8_MAX _I8_MAX

INT16_MIN ((int16_t)_I16_MIN)

INT16_MAX _I16_MAX

INT32_MIN ((int32_t)_I32_MIN)

INT32_MAX _I32_MAX

INT64_MIN ((int64_t)_I64_MIN)

INT64_MAX _I64_MAX

UINT8_MAX _UI8_MAX

UINT16_MAX _UI16_MAX

UINT32_MAX _UI32_MAX

UINT64_MAX _UI64_MAX

INT_LEAST8_MIN INT8_MIN

INT_LEAST8_MAX INT8_MAX

INT_LEAST16_MIN INT16_MIN

INT_LEAST16_MAX INT16_MAX

INT_LEAST32_MIN INT32_MIN

INT_LEAST32_MAX INT32_MAX

INT_LEAST64_MIN INT64_MIN

INT_LEAST64_MAX INT64_MAX

UINT_LEAST8_MAX UINT8_MAX

UINT_LEAST16_MAX UINT16_MAX

UINT_LEAST32_MAX UINT32_MAX

UINT_LEAST64_MAX UINT64_MAX

INT_FAST8_MIN INT8_MIN

INT_FAST8_MAX INT8_MAX

INT_FAST16_MIN INT16_MIN

INT_FAST16_MAX INT16_MAX

INT_FAST32_MIN INT32_MIN

INT_FAST32_MAX INT32_MAX

INT_FAST64_MIN INT64_MIN

INT_FAST64_MAX INT64_MAX

UINT_FAST8_MAX UINT8_MAX

UINT_FAST16_MAX UINT16_MAX

UINT_FAST32_MAX UINT32_MAX

UINT_FAST64_MAX UINT64_MAX

INTPTR_MIN INT32_MIN

INTPTR_MAX INT32_MAX

UINTPTR_MAX UINT32_MAX

INTMAX_MIN INT64_MIN

INTMAX_MAX INT64_MAX

UINTMAX_MAX UINT64_MAX

PTRDIFF_MIN _I32_MIN

PTRDIFF_MAX _I32_MAX

SIG_ATOMIC_MIN INT_MIN

SIG_ATOMIC_MAX INT_MAX

SIZE_MAX _UI32_MAX

WCHAR_MIN 0

WCHAR_MAX _UI16_MAX

WINT_MIN 0

WINT_MAX _UI16_MAX

INT8_C(val)
val##i8

INT16_C(val)
val##i16

INT32_C(val)
val##i32

INT64_C(val)
val##i64

UINT8_C(val)
val##ui8

UINT16_C(val)
val##ui16

UINT32_C(val)
val##ui32

UINT64_C(val)
val##ui64

INTMAX_C INT64_C

UINTMAX_C UINT64_C

Typedefs

Typedefs (amqp.h)

typedef int amqp_boolean_t

boolean type 0 = false, true otherwise

Since
v0.1

typedef uint32_t amqp_method_number_t

Method number

Since
v0.1

typedef uint32_t amqp_flags_t

Bitmask for flags

Since
v0.1

typedef uint16_t amqp_channel_t

Channel type

Since
v0.1

Typedefs (amqp_openssl_bio.h)

typedef BIO_METHOD * BIO_METHOD_PTR

Typedefs (amqp_socket.h)

typedef ssize_t(* amqp_socket_send_fn)(void *, const void *, size_t, int)

typedef ssize_t(* amqp_socket_recv_fn)(void *, void *, size_t, int)

typedef int(* amqp_socket_open_fn)(void *, const char *, int, const struct timeval *)

typedef int(* amqp_socket_close_fn)(void *, amqp_socket_close_enum)

typedef int(* amqp_socket_get_sockfd_fn)(void *)

typedef void(* amqp_socket_delete_fn)(void *)

Typedefs (threads.h)

typedef SRWLOCK pthread_mutex_t

Typedefs (stdint.h)

typedef signed char int8_t

typedef signed short int16_t

typedef signed int int32_t

typedef unsigned char uint8_t

typedef unsigned short uint16_t

typedef unsigned int uint32_t

typedef signed __int64 int64_t

typedef unsigned __int64 uint64_t

Mentioned in

typedef int8_t int_least8_t

typedef int16_t int_least16_t

typedef int32_t int_least32_t

typedef int64_t int_least64_t

typedef uint8_t uint_least8_t

typedef uint16_t uint_least16_t

typedef uint32_t uint_least32_t

typedef uint64_t uint_least64_t

typedef int8_t int_fast8_t

typedef int16_t int_fast16_t

typedef int32_t int_fast32_t

typedef int64_t int_fast64_t

typedef uint8_t uint_fast8_t

typedef uint16_t uint_fast16_t

typedef uint32_t uint_fast32_t

typedef uint64_t uint_fast64_t

typedef signed int intptr_t

typedef unsigned int uintptr_t

typedef int64_t intmax_t

typedef uint64_t uintmax_t

Variables

Variables (amqp.h)

const amqp_bytes_t amqp_empty_bytes

Empty bytes structure

Since
v0.2
Mentioned in

Examples / amqp_consumer.c

Examples / amqp_listen.c

Examples / amqp_listenq.c

Examples / amqp_rpc_sendstring_client.c

const amqp_table_t amqp_empty_table

Empty table structure

Since
v0.2
Mentioned in

Examples / amqp_bind.c

Examples / amqp_consumer.c

Examples / amqp_exchange_declare.c

Examples / amqp_listen.c

Examples / amqp_listenq.c

Examples / amqp_rpc_sendstring_client.c

Examples / amqp_unbind.c

const amqp_array_t amqp_empty_array

Empty table array structure

Since
v0.2

Variables (amqp_api.c)

const char * base_error_strings

const char * tcp_error_strings = { "a socket error occurred", "socket library initialization failed"}

const char * ssl_error_strings = { "a SSL error occurred", "SSL hostname verification failed", "SSL peer cert verification failed", "SSL handshake failed", "SSL setting engine failed"}

const char * unknown_error_string = "(unknown error)"

const amqp_bytes_t amqp_empty_bytes = {0, NULL}

Mentioned in

const amqp_table_t amqp_empty_table = {0, NULL}

Mentioned in

const amqp_array_t amqp_empty_array = {0, NULL}

Variables (amqp_openssl.c)

pthread_mutex_t * amqp_openssl_lockarray = NULL

pthread_mutex_t openssl_init_mutex = PTHREAD_MUTEX_INITIALIZER

amqp_boolean_t do_initialize_openssl = 1

amqp_boolean_t openssl_initialized = 0

amqp_boolean_t openssl_bio_initialized = 0

int openssl_connections = 0

ENGINE * openssl_engine = NULL

const struct amqp_socket_class_t amqp_ssl_socket_class = { amqp_ssl_socket_send, amqp_ssl_socket_recv, amqp_ssl_socket_open, amqp_ssl_socket_close, amqp_ssl_socket_get_sockfd, amqp_ssl_socket_delete }

Variables (amqp_openssl_bio.c)

int amqp_ssl_bio_initialized = 0

Variables (amqp_tcp_socket.c)

const struct amqp_socket_class_t amqp_tcp_socket_class = { amqp_tcp_socket_send, amqp_tcp_socket_recv, amqp_tcp_socket_open, amqp_tcp_socket_close, amqp_tcp_socket_get_sockfd, amqp_tcp_socket_delete }






Add Discussion as Guest

Log in to DocsForge