Internal - Low level protocol description
type reply_text = Amqp_client_lib.Types.shortstrThe localised reply text. This text can be logged as an aid to resolving issues.
type path = Amqp_client_lib.Types.shortstrUnconstrained.
type reply_code = Amqp_client_lib.Types.shortThe reply code. The AMQ reply codes are defined as constants at the start of this formal specification.
type class_id = Amqp_client_lib.Types.shorttype message_count = Amqp_client_lib.Types.longThe number of messages in the queue, which will be zero for newly-declared queues. This is the number of messages present in the queue, and committed if the channel on which they were published is transacted, that are not waiting acknowledgement.
type peer_properties = Amqp_client_lib.Types.tableThis table provides a set of peer properties, used for identification, debugging, and general information.
type method_id = Amqp_client_lib.Types.shorttype exchange_name = Amqp_client_lib.Types.shortstrThe exchange name is a client-selected string that identifies the exchange for publish methods.
type no_wait = Amqp_client_lib.Types.bitIf set, the server will not respond to the method. The client should not wait for a reply method. If the server could not complete the method it will raise a channel or connection exception.
type delivery_tag = Amqp_client_lib.Types.longlongThe server-assigned and channel-specific delivery tag
type no_ack = Amqp_client_lib.Types.bitIf this field is set the server does not expect acknowledgements for messages. That is, when a message is delivered to the client the server assumes the delivery will succeed and immediately dequeues it. This functionality may increase performance but at the cost of reliability. Messages can get lost if a client dies before they are delivered to the application.
type consumer_tag = Amqp_client_lib.Types.shortstrIdentifier for the consumer, valid within the current channel.
type queue_name = Amqp_client_lib.Types.shortstrThe queue name identifies the queue within the vhost. In methods where the queue name may be blank, and that has no specific significance, this refers to the 'current' queue for the channel, meaning the last queue that the client declared on the channel. If the client did not declare a queue, and the method needs a queue name, this will result in a 502 (syntax error) channel exception.
type redelivered = Amqp_client_lib.Types.bitThis indicates that the message has been previously delivered to this or another client.
type no_local = Amqp_client_lib.Types.bitIf the no-local field is set the server will not send messages to the connection that published them.
module Confirm : sig ... endThe Confirm class allows publishers to put the channel in confirm mode and subsequently be notified when messages have been handled by the broker. The intention is that all messages published on a channel in confirm mode will be acknowledged at some point. By acknowledging a message the broker assumes responsibility for it and indicates that it has done something it deems reasonable with it. Unroutable mandatory or immediate messages are acknowledged right after the Basic.Return method. Messages are acknowledged when all queues to which the message has been routed have either delivered the message and received an acknowledgement (if required), or enqueued the message (and persisted it if required). Published messages are assigned ascending sequence numbers, starting at 1 with the first Confirm.Select method. The server confirms messages by sending Basic.Ack methods referring to these sequence numbers.
module Tx : sig ... endThe Tx class allows publish and ack operations to be batched into atomic units of work. The intention is that all publish and ack requests issued within a transaction will complete successfully or none of them will. Servers SHOULD implement atomic transactions at least where all publish or ack requests affect a single queue. Transactions that cover multiple queues may be non-atomic, given that queues can be created and destroyed asynchronously, and such events do not form part of any transaction. Further, the behaviour of transactions with respect to the immediate and mandatory flags on Basic.Publish methods is not defined.
module Basic : sig ... endThe Basic class provides methods that support an industry-standard messaging model.
module Queue : sig ... endQueues store and forward messages. Queues can be configured in the server or created at runtime. Queues must be attached to at least one exchange in order to receive messages from publishers.
module Exchange : sig ... endExchanges match and distribute messages across queues. Exchanges can be configured in the server or declared at runtime.
module Channel : sig ... endThe channel class provides methods for a client to establish a channel to a server and for both peers to operate the channel thereafter.
module Connection : sig ... endThe connection class provides methods for a client to establish a network connection to a server, and for both peers to operate the connection thereafter.