Fixes correlationId on publish

Author: dustindoiron

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

@@ -98,12 +98,14 @@ public function pushRaw($payload, $queue = null, array $options = [])
 
         // push job to a queue
         $message = new AMQPMessage($payload, $headers);
-        $message->set('correlation_id', $this->correlationId ?: uniqid());
+
+        $correlationId = $this->getCorrelationId();
+        $message->set('correlation_id', $correlationId);
 
         // push task to a queue
         $this->channel->basic_publish($message, $exchange, $queue);
 
-        return $this->message->get('correlation_id');
+        return $correlationId;
     }
 
     /**
@@ -266,4 +268,14 @@ public function setCorrelationId($id)
     {
         $this->correlationId = $id;
     }
+
+    /**
+     * Retrieves the correlation id, or a unique id
+     *
+     * @return string
+     */
+    public function getCorrelationId()
+    {
+        return $this->correlationId ?: uniqid();
+    }
 }