Fix x-delay header

utip · Dec 30, 2021 · 1c43df1 · 1c43df1
1 parent 1a2bdca
commit 1c43df1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/RabbitMqDelayPluginDelayStrategy.php b/RabbitMqDelayPluginDelayStrategy.php
@@ -18,6 +18,7 @@ public function delayMessage(AmqpContext $context, AmqpDestination $dest, AmqpMe
     {
         $delayMessage = $context->createMessage($message->getBody(), $message->getProperties(), $message->getHeaders());
         $delayMessage->setProperty('x-delay', (int) $delay);
+        $delayMessage->setHeader('x-delay', $delay);
         $delayMessage->setRoutingKey($message->getRoutingKey());
 
         if ($dest instanceof AmqpTopic) {