redial continually connects to the URL, exiting the program when no longer possible

releaseChannel removes a channel from the registry as the final part of the channel lifecycle

resequence confirms any out of order delivered confirmations

reserved returns true if the integer has been allocated

Every connection should declare the topology they expect

ConnectionState returns basic TLS details of the underlying transport. Returns a zero value when the underlying connection does not implement Connecti

DefaultDial establishes a connection when config.Dial is not provided

* LocalAddr returns the local TCP peer address, or ":0" (the zero value of net.TCPAddr) as a fallback default value if the underlying transport does n

New creates a new consumer state instance, and automatically attempts to connect to the server.

* NotifyBlocked registers a listener for RabbitMQ specific TCP flow control method extensions connection.blocked and connection.unblocked. Flow contr

* NotifyClose registers a listener for close events either initiated by an error accompanying a connection.close method or by a normal shutdown. On n

* NotifyConfirm calls NotifyPublish and starts a goroutine sending ordered Ack and Nack DeliveryTag to the respective channels. For strict ordering,

* NotifyFlow registers a listener for basic.flow methods sent by the server. When `false` is sent on one of the listener channels, all publishers shou

PlainAuth returns a PlainAuth structure based on the parsed URI's Username and Password fields.

Push will push data onto the queue, and wait for a confirm. If no confirms are received until within the resendTimeout, it continuously re-sends messa

* QueueInspect passively declares a queue by name to inspect the current message count and consumer count. Use this method to check how many messages

* QueuePurge removes all messages from the named queue which are not waiting to be acknowledged. Messages that have been delivered but have not yet b

* Recover redelivers all unacknowledged deliveries on this channel. When requeue is false, messages will be redelivered to the original consumer. Wh

Captures the header for each accepted connection

* TxCommit atomically commits all publishings and acknowledgments for a single queue and immediately start a new transaction. Calling this method wit

* TxRollback atomically rolls back all publishings and acknowledgments for a single queue and immediately start a new transaction. Calling this metho

UnsafePush will push to the queue without checking for confirmation. It returns an error if it fails to connect. No guarantees are provided for whethe

On key conflict, close the previous channel.

allocateChannel records but does not open a new channel with a unique id. This method is the initial part of the channel lifecycle and paired with rel

Pulls out the CRC and verifies the remaining content against the CRC

changeChannel takes a new channel to the queue, and updates the channel listeners to reflect this.

changeConnection takes a new connection to the queue, and updates the close listener to reflect this.

One would typically keep a channel of publishings, a sequence number, and a set of unacknowledged sequence numbers and loop until the publishing chann

connect will create a new AMQP connection

All methods sent to the connection channel should be synchronous so we can handle them directly without a framing component

section 2.3.7: "When a peer decides to close a channel or connection, it sends a Close method. The receiving peer MUST respond to a Close with a Clos

Creates a random body size with a leading 32-bit CRC in network byte order that verifies the remaining slice

handleReconnect will wait for a channel error and then continuously attempt to re-initialize both channels

handleReconnect will wait for a connection error on notifyConnClose, and then continuously attempt to reconnect.

Ensures that at least one frame is being sent at the tuned interval with a jitter tolerance of 1s

identity returns the same host/process unique string for the lifetime of this process so that subscriber reconnections reuse the same queue name.

init will initialize channel & declare queue

Convenience method to inspect the Connection.Properties["capabilities"] Table for server identified capabilities like "basic.ack" or "confirm.select".

openChannel allocates and opens a channel, must be paired with closeChannel

openComplete performs any final Connection initialization dependent on the connection handshake and clears any state needed for TLS and AMQP handshaki

Finds the first mechanism preferred by the client that the server supports.

publish publishes messages to a reconnecting session to a fanout exchange. It receives from the application specific source of messages.

read is this application's translation to the message format, scanning from stdin.

Reads each frame off the IO and hand off to the connection object that will demux the streams and dispatch to one of the opened channels or handle on

shutdown is called by Connection after the channel has been removed from the connection registry.

subscribe consumes deliveries from an exclusive queue from a fanout exchange and sends to the application specific messages chan.

see writeShortstr

write is this application's subscriber of application messages, printing to stdout.

* 'A': []interface{} 'D': Decimal 'F': Table 'I': int32 'S': string 'T': time.Time 'V': nil 'b': byte 'd': float64 'f': float32 'l': int64 's': int16

AMQPlainAuth returns a PlainAuth structure based on the parsed URI's Username and Password fields.

* Ack acknowledges a delivery by its delivery tag when having been consumed with Channel.Consume or Channel.Get. Ack acknowledges all message receive

* Ack delegates an acknowledgement through the Acknowledger interface that the client or server has finished work on a delivery. All deliveries in AM

Close will cleanly shutdown the channel and connection.

Close closes all listeners, discarding any out of sequence confirmations