Skip to content

Commit 4f5f862

Browse files
committed
fix bug
1 parent b9e0b86 commit 4f5f862

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/Consumer.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
namespace iamfarhad\LaravelRabbitMQ;
44

55
use Exception;
6-
use Illuminate\Container\Container;
6+
use Illuminate\Container\Cosntainer;
77
use Illuminate\Queue\Worker;
88
use Illuminate\Queue\WorkerOptions;
99
use PhpAmqpLib\Channel\AMQPChannel;

src/RabbitQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -263,7 +263,7 @@ private function declareExchange(
263263
*/
264264
public function getJobClass(): string
265265
{
266-
$job = Arr::get($this->options, 'job', RabbitMQJob::class);
266+
$job = config('queue.connections.rabbitmq.options.queue.job');
267267

268268
throw_if(
269269
! is_a($job, RabbitMQJob::class, true),

0 commit comments

Comments
 (0)