diff --git a/src/WorkerProvider/WorkerServiceProvider.php b/src/WorkerProvider/WorkerServiceProvider.php index 1e32c58..2a2760e 100644 --- a/src/WorkerProvider/WorkerServiceProvider.php +++ b/src/WorkerProvider/WorkerServiceProvider.php @@ -64,7 +64,10 @@ public function register(Application $app) }); $app['alchemy_worker.commands.run_dispatcher_command'] = $app->share(function (Application $app) { - return new DispatchingConsumerCommand($app['alchemy_worker.message_dispatcher']); + return new DispatchingConsumerCommand( + $app['alchemy_worker.message_dispatcher'], + $app['alchemy_worker.worker_invoker'] + ); }); $app['alchemy_worker.commands.run_worker_command'] = $app->share(function (Application $app) {