[async-command][async-events] Do not use deprecated classes.

Author: makasim

RunCommandProcessor.php

@@ -4,13 +4,13 @@
 
 use Enqueue\Client\CommandSubscriberInterface;
 use Enqueue\Consumption\Result;
-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 Symfony\Component\Process\PhpExecutableFinder;
 use Symfony\Component\Process\Process;
 
-final class RunCommandProcessor implements PsrProcessor, CommandSubscriberInterface
+final class RunCommandProcessor implements Processor, CommandSubscriberInterface
 {
     /**
      * @var string
@@ -22,7 +22,7 @@ public function __construct(string $projectDir)
         $this->projectDir = $projectDir;
     }
 
-    public function process(PsrMessage $message, PsrContext $context): Result
+    public function process(Message $message, Context $context): Result
     {
         $command = RunCommand::jsonUnserialize($message->getBody());
 

Tests/Functional/UseCasesTest.php

@@ -8,7 +8,7 @@
 use Enqueue\Consumption\Result;
 use Enqueue\Null\NullContext;
 use Enqueue\Null\NullMessage;
-use Interop\Queue\PsrMessage;
+use Interop\Queue\Message;
 use PHPUnit\Framework\TestCase;
 
 /**
@@ -20,15 +20,15 @@ public function testRunSimpleCommandAndReturnOutput()
     {
         $runCommand = new RunCommand('foo');
 
-        $psrMessage = new NullMessage(json_encode($runCommand));
-        $psrMessage->setReplyTo('aReplyToQueue');
+        $Message = new NullMessage(json_encode($runCommand));
+        $Message->setReplyTo('aReplyToQueue');
 
         $processor = new RunCommandProcessor(__DIR__);
 
-        $result = $processor->process($psrMessage, new NullContext());
+        $result = $processor->process($Message, new NullContext());
 
         $this->assertInstanceOf(Result::class, $result);
-        $this->assertInstanceOf(PsrMessage::class, $result->getReply());
+        $this->assertInstanceOf(Message::class, $result->getReply());
 
         $replyMessage = $result->getReply();
 

Tests/RunCommandProcessorTest.php

@@ -5,7 +5,7 @@
 use Enqueue\AsyncCommand\Commands;
 use Enqueue\AsyncCommand\RunCommandProcessor;
 use Enqueue\Client\CommandSubscriberInterface;
-use Interop\Queue\PsrProcessor;
+use Interop\Queue\Processor;
 use PHPUnit\Framework\TestCase;
 
 class RunCommandProcessorTest extends TestCase
@@ -14,7 +14,7 @@ public function testShouldImplementProcessorInterface()
     {
         $rc = new \ReflectionClass(RunCommandProcessor::class);
 
-        $this->assertTrue($rc->implementsInterface(PsrProcessor::class));
+        $this->assertTrue($rc->implementsInterface(Processor::class));
     }
 
     public function testShouldImplementCommandSubscriberInterfaceInterface()