Documentation
¶
Overview ¶
Package internal houses development helpers and should not be consumed by users.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Confirmation ¶
type Confirmation struct {
// The original confirmation message, embedded in our struct so it can act as a
// drop-in replacement
streadway.Confirmation
// When DisconnectOrphan value is true, this confirmation was never received due to
// a connection disruption, and is being reported as a NACK. However, it is possible
// that this message DID successfully reach the server, and only the confirmation
// response was never received.
DisconnectOrphan bool
}
Confirmation notifies the acknowledgment or negative acknowledgement of a publishing identified by its delivery tag. Use NotifyPublish on the Channel to consume these events.
--
ROGER NOTE: As streadway/amqp.Confirmation, but with additional data on whether this confirmation was received directly from the broker, or created to fill in a gap in delivery tags that occurred due to an unexpected disconnection.
type Delivery ¶
type Delivery struct {
// The original delivery from the underlying channel, embedded in our struct so it
// can act as a drop-in replacement
streadway.Delivery
// TagOffset is the offset applied to our Delivery tag to create a continuous stream
// of delivery tag values across disconnects.
TagOffset uint64
}
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 or Channel.Get.
--
ROGER NOTE: As streadway/amqp.Delivery, but with additional data specifying the tag offset that was applied to this delivery to create a continuous, non-doubled delivery tags across disconnect.
func NewDelivery ¶
func NewDelivery( orig streadway.Delivery, acknowledger streadway.Acknowledger, ) Delivery
NewDelivery created a new Delivery object from an original source streadway.Delivery value plus our new Acknowledger.
Source Files