From 8f0e2742fd529f5803aa6679bd6715197fed7423 Mon Sep 17 00:00:00 2001 From: cdeluce Date: Mon, 18 Oct 2021 13:48:39 +0200 Subject: [PATCH] add RoutingKey getter for Delivery --- amqp.go | 1 + amqp/delivery.go | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/amqp.go b/amqp.go index 100ebf9..3af3471 100644 --- a/amqp.go +++ b/amqp.go @@ -66,6 +66,7 @@ type ( MessageId() string ContentType() string Timestamp() time.Time + RoutingKey() string } // Confirmation is an interface to confrimation messages diff --git a/amqp/delivery.go b/amqp/delivery.go index aeda537..a1a9c28 100644 --- a/amqp/delivery.go +++ b/amqp/delivery.go @@ -38,3 +38,7 @@ func (d *Delivery) Timestamp() time.Time { func (d *Delivery) ContentType() string { return d.Delivery.ContentType } + +func (d *Delivery) RoutingKey() string { + return d.Delivery.RoutingKey +}