diff --git a/src/Queue/Jobs/RabbitMQJob.php b/src/Queue/Jobs/RabbitMQJob.php
index a534b28c..cd6cde98 100644
--- a/src/Queue/Jobs/RabbitMQJob.php
+++ b/src/Queue/Jobs/RabbitMQJob.php
@@ -37,6 +37,7 @@ public function __construct(
         $this->consumer = $consumer;
         $this->message = $message;
         $this->queue = $consumer->getQueue()->getQueueName();
+        $this->connectionName = $connection->getConnectionName();
     }
 
     /**
diff --git a/tests/Queue/Jobs/RabbitMQJobTest.php b/tests/Queue/Jobs/RabbitMQJobTest.php
index 3ec66a80..9f5695a4 100644
--- a/tests/Queue/Jobs/RabbitMQJobTest.php
+++ b/tests/Queue/Jobs/RabbitMQJobTest.php
@@ -52,14 +52,22 @@ public function testCouldBeConstructedWithExpectedArguments()
             ->willReturn($queue)
         ;
 
+        $connectionMock = $this->createRabbitMQQueueMock();
+        $connectionMock
+            ->expects($this->any())
+            ->method('getConnectionName')
+            ->willReturn('theConnectionName')
+        ;
+        
         $job = new RabbitMQJob(
             new Container(),
-            $this->createRabbitMQQueueMock(),
+            $connectionMock,
             $consumerMock,
             new AmqpMessage()
         );
 
         $this->assertAttributeSame('theQueueName', 'queue', $job);
+        $this->assertSame('theConnectionName', $job->getConnectionName());
     }
 
     /**