From 3083b043f50d6e5643bab3c1864bbb89cc084e0c Mon Sep 17 00:00:00 2001
From: Daniel Fly <dn@smartweb.dk>
Date: Tue, 16 May 2017 15:51:36 +0200
Subject: [PATCH] Added missing connectionName

---
 .../LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php          | 5 ++++-
 .../LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php             | 2 +-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php
index 60cf04e7..a3d35645 100644
--- a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php
+++ b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Jobs/RabbitMQJob.php
@@ -35,19 +35,22 @@ class RabbitMQJob extends Job implements JobContract
      * @param \PhpAmqpLib\Channel\AMQPChannel                             $channel
      * @param string                                                      $queue
      * @param \PhpAmqpLib\Message\AMQPMessage                             $message
+     * @param string                                                      $connectionName
      */
     public function __construct(
         Container $container,
         RabbitMQQueue $connection,
         AMQPChannel $channel,
         $queue,
-        AMQPMessage $message
+        AMQPMessage $message,
+        $connectionName
     ) {
         $this->container = $container;
         $this->connection = $connection;
         $this->channel = $channel;
         $this->queue = $queue;
         $this->message = $message;
+        $this->connectionName = $connectionName;
     }
 
     /**
diff --git a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php
index b5392696..f89a54f9 100644
--- a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php
+++ b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php
@@ -165,7 +165,7 @@ public function pop($queue = null)
             $message = $this->channel->basic_get($queue);
 
             if ($message instanceof AMQPMessage) {
-                return new RabbitMQJob($this->container, $this, $this->channel, $queue, $message);
+                return new RabbitMQJob($this->container, $this, $this->channel, $queue, $message, $this->connectionName);
             }
         } catch (ErrorException $exception) {
             $this->reportConnectionError('pop', $exception);