From a09c7177de0f9ca54fec78571fab93670c74bf42 Mon Sep 17 00:00:00 2001 From: Ali Reza Date: Thu, 20 Sep 2018 17:17:48 +0200 Subject: [PATCH 1/2] add RoutingKey on delivery struct --- amqp/delivery.go | 4 ++++ 1 file changed, 4 insertions(+) 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 +} From d30a7634ee68d9e0dec36275f3aa0ba32cfbadbf Mon Sep 17 00:00:00 2001 From: Ali Reza Date: Thu, 20 Sep 2018 17:23:34 +0200 Subject: [PATCH 2/2] Update amqp.go --- amqp.go | 1 + 1 file changed, 1 insertion(+) 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