Merge pull request #735 from php-enqueue/fix-job-status-processor

fix job status processor

Author: makasim

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(),
         ]);
     }

pkg/job-queue/Tests/JobProcessorTest.php

@@ -169,7 +169,7 @@ public function testCreateChildJobShouldCreateAndSaveJobAndPublishRecalculateRoo
         $producer = $this->createProducerMock();
         $producer
             ->expects($this->once())
-            ->method('sendEvent')
+            ->method('sendCommand')
             ->with(Commands::CALCULATE_ROOT_JOB_STATUS, ['jobId' => 12345])
         ;
 
@@ -246,7 +246,7 @@ public function testStartJobShouldUpdateJobWithRunningStatusAndStartAtTime()
         $producer = $this->createProducerMock();
         $producer
             ->expects($this->once())
-            ->method('sendEvent')
+            ->method('sendCommand')
         ;
 
         $processor = new JobProcessor($storage, $producer);
@@ -316,7 +316,7 @@ public function testSuccessJobShouldUpdateJobWithSuccessStatusAndStopAtTime()
         $producer = $this->createProducerMock();
         $producer
             ->expects($this->once())
-            ->method('sendEvent')
+            ->method('sendCommand')
         ;
 
         $processor = new JobProcessor($storage, $producer);
@@ -386,7 +386,7 @@ public function testFailJobShouldUpdateJobWithFailStatusAndStopAtTime()
         $producer = $this->createProducerMock();
         $producer
             ->expects($this->once())
-            ->method('sendEvent')
+            ->method('sendCommand')
         ;
 
         $processor = new JobProcessor($storage, $producer);
@@ -456,7 +456,7 @@ public function testCancelJobShouldUpdateJobWithCancelStatusAndStoppedAtTimeAndS
         $producer = $this->createProducerMock();
         $producer
             ->expects($this->once())
-            ->method('sendEvent')
+            ->method('sendCommand')
         ;
 
         $processor = new JobProcessor($storage, $producer);