message is the application type for a message. This can contain identity, or a reference to the recevier chan for further demuxing.

Table stores user supplied fields of the following types: bool byte float32 float64 int int16 int32 int64 nil string time.Time amqp.Decimal amqp.Tabl

AMQPlainAuth is similar to PlainAuth

Acknowledger notifies the server of successful or failed consumption of delivieries via identifier found in the Delivery.DeliveryTag field. Applicati

Authentication interface provides a means for different SASL authentication mechanisms to be used during connection tuning.

Blocking notifies the server's TCP flow control of the Connection. When a server hits a memory or disk alarm it will block all connections until the

* Channel represents an AMQP channel. Used as a context for valid message exchange. Errors on methods with this Channel as a receiver means this chan

Config is used in DialConfig and Open to specify the desired tuning parameters used during a connection open handshake. The negotiated tuning will be

Confirmation notifies the acknowledgment or negative acknowledgement of a publishing identified by its delivery tag. Use NotifyPublish on the Channel

Connection manages the serialization and deserialization of frames from IO and dispatches the frames to the appropriate channel. All RPC methods and

Decimal matches the AMQP decimal type. Scale is the number of decimal digits Scale == 2, Value == 12345, Decimal == 123.45

Delivery captures the fields for a previously delivered message resident in a queue to be delivered by the server to a consumer from Channel.Consume o

Error captures the code and reason a channel or connection has been closed by the server.

PlainAuth is a similar to Basic Auth in HTTP.

Publishing captures the client message sent to the server. The fields outside of the Headers table included in this struct mirror the underlying fiel

Queue captures the current server state of the queue on the server returned from Channel.QueueDeclare or Channel.QueueInspect.

Return captures a flattened struct of fields returned by the server when a Publishing is unable to be delivered either due to the `mandatory` flag set

URI represents a parsed AMQP URI string.

allocator maintains a bitset of allocated numbers.

Establish our queue topologies that we are responsible for

* Content is the application data we carry from client-to-client via the AMQP server. Content is, roughly speaking, a set of properties plus a binary

confirms resequences and notifies one or multiple publisher confirmation listeners

Concurrent type that manages the consumerTag -> ingress consumerBuffer mapping

* The base interface implemented as: 2.3.5 frame Details All frames consist of a header (7 octets), a payload of arbitrary size, and a 'frame-end'

* Certain methods (such as Basic.Publish, Basic.Deliver, etc.) are formally defined as carrying content. When a peer sends such a method frame, it al

* Heartbeating is a technique designed to undo one of TCP/IP's features, namely its ability to recover from a broken physical connection by closing on

* Method frames carry the high-level protocol commands (which we call "methods"). One method frame carries one command. The method frame payload has

Used by header frames to capture routing and header information

Implements the frame interface for Connection RPC