Fix command initialisation in service provider

alchemy-fr · Dec 6, 2016 · 5081532 · 5081532
1 parent ae83862
commit 5081532
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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) {