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 +}