diff --git a/v2/brokers/amqp/amqp.go b/v2/brokers/amqp/amqp.go
index b26229ca..106ffda8 100644
--- a/v2/brokers/amqp/amqp.go
+++ b/v2/brokers/amqp/amqp.go
@@ -372,6 +372,7 @@ func (b *Broker) delay(signature *tasks.Signature, delayMs int64) error {
 		// Time after that the queue will be deleted.
 		"x-expires": delayMs * 2,
 	}
+
 	conn, channel, _, _, _, err := b.Connect(
 		b.GetConfig().Broker,
 		b.GetConfig().MultipleBrokerSeparator,
@@ -402,6 +403,7 @@ func (b *Broker) delay(signature *tasks.Signature, delayMs int64) error {
 			ContentType:  "application/json",
 			Body:         message,
 			DeliveryMode: amqp.Persistent,
+			Priority:     signature.Priority,
 		},
 	); err != nil {
 		return err