[simple-client] Do not use deprecated classes.

Author: makasim

pkg/simple-client/SimpleClient.php

@@ -25,10 +25,10 @@
 use Enqueue\Rpc\Promise;
 use Enqueue\Rpc\RpcFactory;
 use Enqueue\Symfony\DependencyInjection\TransportFactory;
-use Interop\Queue\PsrProcessor;
+use Interop\Queue\Processor;
 use Symfony\Component\Config\Definition\Builder\TreeBuilder;
 use Symfony\Component\Config\Definition\NodeInterface;
-use Symfony\Component\Config\Definition\Processor;
+use Symfony\Component\Config\Definition\Processor as ConfigProcessor;
 
 final class SimpleClient
 {
@@ -110,16 +110,16 @@ public function __construct($config)
     }
 
     /**
-     * @param callable|PsrProcessor $processor
+     * @param callable|Processor $processor
      */
     public function bindTopic(string $topic, $processor, string $processorName = null): void
     {
         if (is_callable($processor)) {
             $processor = new CallbackProcessor($processor);
         }
 
-        if (false == $processor instanceof PsrProcessor) {
-            throw new \LogicException('The processor must be either callable or instance of PsrProcessor');
+        if (false == $processor instanceof Processor) {
+            throw new \LogicException('The processor must be either callable or instance of Processor');
         }
 
         $processorName = $processorName ?: uniqid(get_class($processor));
@@ -129,16 +129,16 @@ public function bindTopic(string $topic, $processor, string $processorName = nul
     }
 
     /**
-     * @param callable|PsrProcessor $processor
+     * @param callable|Processor $processor
      */
     public function bindCommand(string $command, $processor, string $processorName = null): void
     {
         if (is_callable($processor)) {
             $processor = new CallbackProcessor($processor);
         }
 
-        if (false == $processor instanceof PsrProcessor) {
-            throw new \LogicException('The processor must be either callable or instance of PsrProcessor');
+        if (false == $processor instanceof Processor) {
+            throw new \LogicException('The processor must be either callable or instance of Processor');
         }
 
         $processorName = $processorName ?: uniqid(get_class($processor));
@@ -211,7 +211,7 @@ public function setupBroker(): void
 
     public function build(array $configs): void
     {
-        $configProcessor = new Processor();
+        $configProcessor = new ConfigProcessor();
         $simpleClientConfig = $configProcessor->process($this->createConfiguration(), $configs);
 
         if (isset($simpleClientConfig['transport']['factory_service'])) {

pkg/simple-client/Tests/Functional/SimpleClientTest.php

@@ -7,8 +7,8 @@
 use Enqueue\Consumption\Extension\LimitConsumptionTimeExtension;
 use Enqueue\Consumption\Result;
 use Enqueue\SimpleClient\SimpleClient;
-use Interop\Queue\PsrMessage;
-use Interop\Queue\PurgeQueueNotSupportedException;
+use Interop\Queue\Exception\PurgeQueueNotSupportedException;
+use Interop\Queue\Message;
 use PHPUnit\Framework\TestCase;
 
 /**
@@ -75,7 +75,7 @@ public function testSendEventWithOneSubscriber(array $config, string $timeLimit)
 
         $client = new SimpleClient($config);
 
-        $client->bindTopic('foo_topic', function (PsrMessage $message) use (&$actualMessage) {
+        $client->bindTopic('foo_topic', function (Message $message) use (&$actualMessage) {
             $actualMessage = $message;
 
             return Result::ACK;
@@ -92,7 +92,7 @@ public function testSendEventWithOneSubscriber(array $config, string $timeLimit)
             new LimitConsumedMessagesExtension(2),
         ]));
 
-        $this->assertInstanceOf(PsrMessage::class, $actualMessage);
+        $this->assertInstanceOf(Message::class, $actualMessage);
         $this->assertSame('Hello there!', $actualMessage->getBody());
     }