diff --git a/src/Consumer.php b/src/Consumer.php index 8d60582..3440552 100644 --- a/src/Consumer.php +++ b/src/Consumer.php @@ -3,7 +3,7 @@ namespace iamfarhad\LaravelRabbitMQ; use Exception; -use Illuminate\Container\Container; +use Illuminate\Container\Cosntainer; use Illuminate\Queue\Worker; use Illuminate\Queue\WorkerOptions; use PhpAmqpLib\Channel\AMQPChannel; diff --git a/src/RabbitQueue.php b/src/RabbitQueue.php index b1d1804..357eee5 100644 --- a/src/RabbitQueue.php +++ b/src/RabbitQueue.php @@ -263,7 +263,7 @@ private function declareExchange( */ public function getJobClass(): string { - $job = Arr::get($this->options, 'job', RabbitMQJob::class); + $job = config('queue.connections.rabbitmq.options.queue.job'); throw_if( ! is_a($job, RabbitMQJob::class, true),