corvus-ch/rabbitmq-cli-consumer

package delivery

import (
    "github.com/streadway/amqp"
)

// Info represents the delivery info of an amqp message.
type Info struct {
    MessageCount uint32 `json:"message_count"`
    ConsumerTag  string `json:"consumer_tag"`
    DeliveryTag  uint64 `json:"delivery_tag"`
    Redelivered  bool   `json:"redelivered"`
    Exchange     string `json:"exchange"`
    RoutingKey   string `json:"routing_key"`
}

// NewDeliveryInfo creates a new delivery info struct from the AMQP message.
func NewDeliveryInfo(d amqp.Delivery) Info {
    return Info{
        ConsumerTag:  d.ConsumerTag,
        MessageCount: d.MessageCount,
        DeliveryTag:  d.DeliveryTag,
        Redelivered:  d.Redelivered,
        Exchange:     d.Exchange,
        RoutingKey:   d.RoutingKey,
    }
}