Migrate from psr-queeu to queue-interop

Author: makasim

Client/RedisDriver.php

@@ -7,10 +7,10 @@
 use Enqueue\Client\Message;
 use Enqueue\Client\MessagePriority;
 use Enqueue\Client\Meta\QueueMetaRegistry;
-use Enqueue\Psr\PsrMessage;
 use Enqueue\Redis\RedisContext;
 use Enqueue\Redis\RedisDestination;
 use Enqueue\Redis\RedisMessage;
+use Interop\Queue\PsrMessage;
 use Psr\Log\LoggerInterface;
 
 class RedisDriver implements DriverInterface

RedisConnectionFactory.php

@@ -2,7 +2,7 @@
 
 namespace Enqueue\Redis;
 
-use Enqueue\Psr\PsrConnectionFactory;
+use Interop\Queue\PsrConnectionFactory;
 use Predis\Client;
 
 class RedisConnectionFactory implements PsrConnectionFactory

RedisConsumer.php

@@ -2,9 +2,9 @@
 
 namespace Enqueue\Redis;
 
-use Enqueue\Psr\InvalidMessageException;
-use Enqueue\Psr\PsrConsumer;
-use Enqueue\Psr\PsrMessage;
+use Interop\Queue\InvalidMessageException;
+use Interop\Queue\PsrConsumer;
+use Interop\Queue\PsrMessage;
 
 class RedisConsumer implements PsrConsumer
 {

RedisContext.php

@@ -2,11 +2,11 @@
 
 namespace Enqueue\Redis;
 
-use Enqueue\Psr\InvalidDestinationException;
-use Enqueue\Psr\PsrContext;
-use Enqueue\Psr\PsrDestination;
-use Enqueue\Psr\PsrQueue;
-use Enqueue\Psr\PsrTopic;
+use Interop\Queue\InvalidDestinationException;
+use Interop\Queue\PsrContext;
+use Interop\Queue\PsrDestination;
+use Interop\Queue\PsrQueue;
+use Interop\Queue\PsrTopic;
 
 class RedisContext implements PsrContext
 {

RedisDestination.php

@@ -2,8 +2,8 @@
 
 namespace Enqueue\Redis;
 
-use Enqueue\Psr\PsrQueue;
-use Enqueue\Psr\PsrTopic;
+use Interop\Queue\PsrQueue;
+use Interop\Queue\PsrTopic;
 
 class RedisDestination implements PsrQueue, PsrTopic
 {

RedisMessage.php

@@ -2,7 +2,7 @@
 
 namespace Enqueue\Redis;
 
-use Enqueue\Psr\PsrMessage;
+use Interop\Queue\PsrMessage;
 
 class RedisMessage implements PsrMessage, \JsonSerializable
 {

RedisProducer.php

@@ -2,11 +2,11 @@
 
 namespace Enqueue\Redis;
 
-use Enqueue\Psr\InvalidDestinationException;
-use Enqueue\Psr\InvalidMessageException;
-use Enqueue\Psr\PsrDestination;
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrProducer;
+use Interop\Queue\InvalidDestinationException;
+use Interop\Queue\InvalidMessageException;
+use Interop\Queue\PsrDestination;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrProducer;
 
 class RedisProducer implements PsrProducer
 {

ServerException.php

@@ -2,7 +2,7 @@
 
 namespace Enqueue\Redis;
 
-use Enqueue\Psr\Exception;
+use Interop\Queue\Exception;
 
 class ServerException extends Exception
 {

Tests/Client/RedisDriverTest.php

@@ -7,12 +7,12 @@
 use Enqueue\Client\Message;
 use Enqueue\Client\MessagePriority;
 use Enqueue\Client\Meta\QueueMetaRegistry;
-use Enqueue\Psr\PsrProducer;
 use Enqueue\Redis\Client\RedisDriver;
 use Enqueue\Redis\RedisContext;
 use Enqueue\Redis\RedisDestination;
 use Enqueue\Redis\RedisMessage;
 use Enqueue\Test\ClassExtensionTrait;
+use Interop\Queue\PsrProducer;
 use PHPUnit\Framework\TestCase;
 
 class RedisDriverTest extends TestCase

Tests/Functional/ConsumptionUseCasesTrait.php

@@ -8,8 +8,8 @@
 use Enqueue\Consumption\Extension\ReplyExtension;
 use Enqueue\Consumption\QueueConsumer;
 use Enqueue\Consumption\Result;
-use Enqueue\Psr\PsrMessage;
 use Enqueue\Redis\RedisContext;
+use Interop\Queue\PsrMessage;
 
 trait ConsumptionUseCasesTrait
 {

Tests/Functional/StubProcessor.php

@@ -2,9 +2,9 @@
 
 namespace Enqueue\Redis\Tests\Functional;
 
-use Enqueue\Psr\PsrContext;
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrContext;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrProcessor;
 
 class StubProcessor implements PsrProcessor
 {

Tests/RedisConnectionFactoryTest.php

@@ -2,10 +2,10 @@
 
 namespace Enqueue\Redis\Tests;
 
-use Enqueue\Psr\PsrConnectionFactory;
 use Enqueue\Redis\RedisConnectionFactory;
 use Enqueue\Redis\RedisContext;
 use Enqueue\Test\ClassExtensionTrait;
+use Interop\Queue\PsrConnectionFactory;
 
 class RedisConnectionFactoryTest extends \PHPUnit\Framework\TestCase
 {

Tests/RedisConsumerTest.php

@@ -2,14 +2,14 @@
 
 namespace Enqueue\Redis\Tests;
 
-use Enqueue\Psr\PsrConsumer;
 use Enqueue\Redis\Redis;
 use Enqueue\Redis\RedisConsumer;
 use Enqueue\Redis\RedisContext;
 use Enqueue\Redis\RedisDestination;
 use Enqueue\Redis\RedisMessage;
 use Enqueue\Redis\RedisProducer;
 use Enqueue\Test\ClassExtensionTrait;
+use Interop\Queue\PsrConsumer;
 
 class RedisConsumerTest extends \PHPUnit\Framework\TestCase
 {

Tests/RedisContextTest.php

@@ -4,15 +4,15 @@
 
 use Enqueue\Null\NullQueue;
 use Enqueue\Null\NullTopic;
-use Enqueue\Psr\InvalidDestinationException;
-use Enqueue\Psr\PsrContext;
 use Enqueue\Redis\Redis;
 use Enqueue\Redis\RedisConsumer;
 use Enqueue\Redis\RedisContext;
 use Enqueue\Redis\RedisDestination;
 use Enqueue\Redis\RedisMessage;
 use Enqueue\Redis\RedisProducer;
 use Enqueue\Test\ClassExtensionTrait;
+use Interop\Queue\InvalidDestinationException;
+use Interop\Queue\PsrContext;
 
 class RedisContextTest extends \PHPUnit\Framework\TestCase
 {

Tests/RedisDestinationTest.php

@@ -2,10 +2,10 @@
 
 namespace Enqueue\Redis\Tests;
 
-use Enqueue\Psr\PsrQueue;
-use Enqueue\Psr\PsrTopic;
 use Enqueue\Redis\RedisDestination;
 use Enqueue\Test\ClassExtensionTrait;
+use Interop\Queue\PsrQueue;
+use Interop\Queue\PsrTopic;
 
 class RedisDestinationTest extends \PHPUnit\Framework\TestCase
 {

Tests/RedisProducerTest.php

@@ -4,14 +4,14 @@
 
 use Enqueue\Null\NullMessage;
 use Enqueue\Null\NullQueue;
-use Enqueue\Psr\InvalidDestinationException;
-use Enqueue\Psr\InvalidMessageException;
-use Enqueue\Psr\PsrProducer;
 use Enqueue\Redis\Redis;
 use Enqueue\Redis\RedisDestination;
 use Enqueue\Redis\RedisMessage;
 use Enqueue\Redis\RedisProducer;
 use Enqueue\Test\ClassExtensionTrait;
+use Interop\Queue\InvalidDestinationException;
+use Interop\Queue\InvalidMessageException;
+use Interop\Queue\PsrProducer;
 use PHPUnit\Framework\TestCase;
 
 class RedisProducerTest extends TestCase

Tests/Spec/RedisMessageTest.php

@@ -2,8 +2,8 @@
 
 namespace Enqueue\Redis\Tests\Spec;
 
-use Enqueue\Psr\Spec\PsrMessageSpec;
 use Enqueue\Redis\RedisMessage;
+use Interop\Queue\Spec\PsrMessageSpec;
 
 class RedisMessageTest extends PsrMessageSpec
 {