fix job status processor

ASKozienko · ASKozienko · commit 356b3ad5f9ce · 2019-01-21T13:40:39.000+02:00
diff --git a/pkg/job-queue/JobProcessor.php b/pkg/job-queue/JobProcessor.php
@@ -260,7 +260,7 @@ protected function saveJob(Job $job)
      */
     protected function sendCalculateRootJobStatusEvent(Job $job)
     {
-        $this->producer->sendEvent(Commands::CALCULATE_ROOT_JOB_STATUS, [
+        $this->producer->sendCommand(Commands::CALCULATE_ROOT_JOB_STATUS, [
             'jobId' => $job->getId(),
         ]);
     }

Original file line number	Diff line number	Diff line change
`@@ -260,7 +260,7 @@ protected function saveJob(Job $job)`
`260`	`260`	`*/`
`261`	`261`	`protected function sendCalculateRootJobStatusEvent(Job $job)`
`262`	`262`	`{`
`263`		`- $this->producer->sendEvent(Commands::CALCULATE_ROOT_JOB_STATUS, [`
	`263`	`+ $this->producer->sendCommand(Commands::CALCULATE_ROOT_JOB_STATUS, [`
`264`	`264`	`'jobId' => $job->getId(),`
`265`	`265`	`]);`
`266`	`266`	`}`