[job-queue] Do not use deprecated classes

Author: makasim

pkg/job-queue/CalculateRootJobStatusProcessor.php

@@ -7,12 +7,12 @@
 use Enqueue\Consumption\Result;
 use Enqueue\JobQueue\Doctrine\JobStorage;
 use Enqueue\Util\JSON;
-use Interop\Queue\PsrContext;
-use Interop\Queue\PsrMessage;
-use Interop\Queue\PsrProcessor;
+use Interop\Queue\Context;
+use Interop\Queue\Message;
+use Interop\Queue\Processor;
 use Psr\Log\LoggerInterface;
 
-class CalculateRootJobStatusProcessor implements PsrProcessor, CommandSubscriberInterface
+class CalculateRootJobStatusProcessor implements Processor, CommandSubscriberInterface
 {
     /**
      * @var JobStorage
@@ -46,7 +46,7 @@ public function __construct(
         $this->logger = $logger;
     }
 
-    public function process(PsrMessage $message, PsrContext $context)
+    public function process(Message $message, Context $context)
     {
         $data = JSON::decode($message->getBody());
 

pkg/job-queue/DependentJobProcessor.php

@@ -2,18 +2,18 @@
 
 namespace Enqueue\JobQueue;
 
-use Enqueue\Client\Message;
+use Enqueue\Client\Message as ClientMessage;
 use Enqueue\Client\ProducerInterface;
 use Enqueue\Client\TopicSubscriberInterface;
 use Enqueue\Consumption\Result;
 use Enqueue\JobQueue\Doctrine\JobStorage;
 use Enqueue\Util\JSON;
-use Interop\Queue\PsrContext;
-use Interop\Queue\PsrMessage;
-use Interop\Queue\PsrProcessor;
+use Interop\Queue\Context;
+use Interop\Queue\Message;
+use Interop\Queue\Processor;
 use Psr\Log\LoggerInterface;
 
-class DependentJobProcessor implements PsrProcessor, TopicSubscriberInterface
+class DependentJobProcessor implements Processor, TopicSubscriberInterface
 {
     /**
      * @var JobStorage
@@ -45,7 +45,7 @@ public function __construct(JobStorage $jobStorage, ProducerInterface $producer,
     /**
      * {@inheritdoc}
      */
-    public function process(PsrMessage $message, PsrContext $context)
+    public function process(Message $message, Context $context)
     {
         $data = JSON::decode($message->getBody());
 
@@ -98,7 +98,7 @@ public function process(PsrMessage $message, PsrContext $context)
         }
 
         foreach ($dependentJobs as $dependentJob) {
-            $message = new Message();
+            $message = new ClientMessage();
             $message->setBody($dependentJob['message']);
 
             if (isset($dependentJob['priority'])) {

pkg/job-queue/Tests/CalculateRootJobStatusProcessorTest.php

@@ -11,7 +11,7 @@
 use Enqueue\JobQueue\Job;
 use Enqueue\JobQueue\Topics;
 use Enqueue\Null\NullMessage;
-use Interop\Queue\PsrContext;
+use Interop\Queue\Context;
 use Psr\Log\LoggerInterface;
 
 class CalculateRootJobStatusProcessorTest extends \PHPUnit\Framework\TestCase
@@ -184,11 +184,11 @@ private function createProducerMock()
     }
 
     /**
-     * @return \PHPUnit_Framework_MockObject_MockObject|PsrContext
+     * @return \PHPUnit_Framework_MockObject_MockObject|Context
      */
     private function createContextMock()
     {
-        return $this->createMock(PsrContext::class);
+        return $this->createMock(Context::class);
     }
 
     /**

pkg/job-queue/Tests/DependentJobProcessorTest.php

@@ -10,7 +10,7 @@
 use Enqueue\JobQueue\Job;
 use Enqueue\JobQueue\Topics;
 use Enqueue\Null\NullMessage;
-use Interop\Queue\PsrContext;
+use Interop\Queue\Context;
 use Psr\Log\LoggerInterface;
 
 class DependentJobProcessorTest extends \PHPUnit\Framework\TestCase
@@ -317,11 +317,11 @@ public function testShouldPublishDependentMessageWithPriority()
     }
 
     /**
-     * @return \PHPUnit_Framework_MockObject_MockObject|PsrContext
+     * @return \PHPUnit_Framework_MockObject_MockObject|Context
      */
     private function createContextMock()
     {
-        return $this->createMock(PsrContext::class);
+        return $this->createMock(Context::class);
     }
 
     /**