Update RabbitMQQueue.php

Author: andriykhc

src/Queue/RabbitMQQueue.php

@@ -187,11 +187,18 @@ function ($payload, $queue, $delay) {
     public function laterRaw($delay, $payload, $queue = null, $attempts = 0)
     {
         $ttl = $this->secondsUntil($delay) * 1000;
+        
+        // default options
+        $options = ['delay' => $delay, 'attempts' => $attempts];
 
         // When no ttl just publish a new message to the exchange or queue
         if ($ttl <= 0) {
-            return $this->pushRaw($payload, $queue, ['delay' => $delay, 'attempts' => $attempts]);
+            return $this->pushRaw($payload, $queue, $options);
         }
+        
+        // Create a main queue to handle delayed messages
+        [$mainDestination, $exchange, $exchangeType, $attempts] = $this->publishProperties($queue, $options);
+        $this->declareDestination($mainDestination, $exchange, $exchangeType);
 
         $destination = $this->getQueue($queue).'.delay.'.$ttl;