diff --git a/amqp.go b/amqp.go index a4358eb..4f94904 100644 --- a/amqp.go +++ b/amqp.go @@ -61,6 +61,7 @@ type ( DeliveryTag() uint64 ConsumerTag() string MessageId() string + RoutingKey() string } // Confirmation is an interface to confrimation messages diff --git a/amqp/delivery.go b/amqp/delivery.go index e23cd44..62bf8ba 100644 --- a/amqp/delivery.go +++ b/amqp/delivery.go @@ -28,3 +28,7 @@ func (d *Delivery) ConsumerTag() string { func (d *Delivery) MessageId() string { return d.Delivery.MessageId } + +func (d *Delivery) RoutingKey() string { + return d.Delivery.RoutingKey +}