Add missing container instance and connectionName to RabbitMQJob

Author: vyuldashev

CHANGELOG.md

@@ -2,7 +2,11 @@
 
 All notable changes to this project will be documented in this file.
 
-## [10.0.0 (2019-12-12)](https://github.com/vyuldashev/laravel-queue-rabbitmq/compare/v9.0...master)
+## [10.0.1 (2019-12-13)](https://github.com/vyuldashev/laravel-queue-rabbitmq/compare/v10.0.0...v10.0.1)
+
+- Add missing container instance and connectionName to RabbitMQJob
+
+## [10.0.0 (2019-12-12)](https://github.com/vyuldashev/laravel-queue-rabbitmq/compare/v9.0...v10.0.0)
 
 - Switch from enqueue to [php-amqplib](https://github.com/php-amqplib/php-amqplib)
 - Fix [#235](https://github.com/vyuldashev/laravel-queue-rabbitmq/issues/235)

src/Queue/Jobs/RabbitMQJob.php

@@ -2,6 +2,7 @@
 
 namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs;
 
+use Illuminate\Container\Container;
 use Illuminate\Contracts\Container\BindingResolutionException;
 use Illuminate\Contracts\Queue\Job as JobContract;
 use Illuminate\Queue\Jobs\Job;
@@ -35,12 +36,16 @@ class RabbitMQJob extends Job implements JobContract
     protected $decoded;
 
     public function __construct(
+        Container $container,
         RabbitMQQueue $rabbitmq,
         AMQPMessage $message,
+        string $connectionName,
         string $queue
     ) {
+        $this->container = $container;
         $this->rabbitmq = $rabbitmq;
         $this->message = $message;
+        $this->connectionName = $connectionName;
         $this->queue = $queue;
         $this->decoded = $this->payload();
     }

src/Queue/RabbitMQQueue.php

@@ -198,7 +198,13 @@ public function pop($queue = null)
 
             /** @var AMQPMessage|null $message */
             if ($message = $this->channel->basic_get($queue)) {
-                return new RabbitMQJob($this, $message, $queue);
+                return new RabbitMQJob(
+                    $this->container,
+                    $this,
+                    $message,
+                    $this->connectionName,
+                    $queue
+                );
             }
         } catch (AMQPProtocolChannelException $exception) {
             // if there is not exchange or queue AMQP will throw exception with code 404