[null] Do not use deprecated classes.

makasim · makasim · commit d8b263889435 · 2018-09-28T14:36:00.000+03:00
diff --git a/pkg/null/NullConnectionFactory.php b/pkg/null/NullConnectionFactory.php
@@ -4,15 +4,15 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrConnectionFactory;
-use Interop\Queue\PsrContext;
+use Interop\Queue\ConnectionFactory;
+use Interop\Queue\Context;
 
-class NullConnectionFactory implements PsrConnectionFactory
+class NullConnectionFactory implements ConnectionFactory
 {
     /**
      * @return NullContext
      */
-    public function createContext(): PsrContext
+    public function createContext(): Context
     {
         return new NullContext();
     }
diff --git a/pkg/null/NullConsumer.php b/pkg/null/NullConsumer.php
@@ -4,49 +4,49 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrConsumer;
-use Interop\Queue\PsrDestination;
-use Interop\Queue\PsrMessage;
-use Interop\Queue\PsrQueue;
+use Interop\Queue\Consumer;
+use Interop\Queue\Destination;
+use Interop\Queue\Message;
+use Interop\Queue\Queue;
 
-class NullConsumer implements PsrConsumer
+class NullConsumer implements Consumer
 {
     /**
-     * @var PsrDestination
+     * @var Destination
      */
     private $queue;
 
-    public function __construct(PsrDestination $queue)
+    public function __construct(Destination $queue)
     {
         $this->queue = $queue;
     }
 
-    public function getQueue(): PsrQueue
+    public function getQueue(): Queue
     {
         return $this->queue;
     }
 
     /**
      * @return NullMessage
      */
-    public function receive(int $timeout = 0): ?PsrMessage
+    public function receive(int $timeout = 0): ?Message
     {
         return null;
     }
 
     /**
      * @return NullMessage
      */
-    public function receiveNoWait(): ?PsrMessage
+    public function receiveNoWait(): ?Message
     {
         return null;
     }
 
-    public function acknowledge(PsrMessage $message): void
+    public function acknowledge(Message $message): void
     {
     }
 
-    public function reject(PsrMessage $message, bool $requeue = false): void
+    public function reject(Message $message, bool $requeue = false): void
     {
     }
 }
diff --git a/pkg/null/NullContext.php b/pkg/null/NullContext.php
@@ -4,21 +4,21 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrConsumer;
-use Interop\Queue\PsrContext;
-use Interop\Queue\PsrDestination;
-use Interop\Queue\PsrMessage;
-use Interop\Queue\PsrProducer;
-use Interop\Queue\PsrQueue;
-use Interop\Queue\PsrSubscriptionConsumer;
-use Interop\Queue\PsrTopic;
+use Interop\Queue\Consumer;
+use Interop\Queue\Context;
+use Interop\Queue\Destination;
+use Interop\Queue\Message;
+use Interop\Queue\Producer;
+use Interop\Queue\Queue;
+use Interop\Queue\SubscriptionConsumer;
+use Interop\Queue\Topic;
 
-class NullContext implements PsrContext
+class NullContext implements Context
 {
     /**
      * @return NullMessage
      */
-    public function createMessage(string $body = '', array $properties = [], array $headers = []): PsrMessage
+    public function createMessage(string $body = '', array $properties = [], array $headers = []): Message
     {
         $message = new NullMessage();
         $message->setBody($body);
@@ -31,52 +31,52 @@ public function createMessage(string $body = '', array $properties = [], array $
     /**
      * @return NullQueue
      */
-    public function createQueue(string $name): PsrQueue
+    public function createQueue(string $name): Queue
     {
         return new NullQueue($name);
     }
 
     /**
      * @return NullQueue
      */
-    public function createTemporaryQueue(): PsrQueue
+    public function createTemporaryQueue(): Queue
     {
         return $this->createQueue(uniqid('', true));
     }
 
     /**
      * @return NullTopic
      */
-    public function createTopic(string $name): PsrTopic
+    public function createTopic(string $name): Topic
     {
         return new NullTopic($name);
     }
 
     /**
      * @return NullConsumer
      */
-    public function createConsumer(PsrDestination $destination): PsrConsumer
+    public function createConsumer(Destination $destination): Consumer
     {
         return new NullConsumer($destination);
     }
 
     /**
      * @return NullProducer
      */
-    public function createProducer(): PsrProducer
+    public function createProducer(): Producer
     {
         return new NullProducer();
     }
 
     /**
      * @return NullSubscriptionConsumer
      */
-    public function createSubscriptionConsumer(): PsrSubscriptionConsumer
+    public function createSubscriptionConsumer(): SubscriptionConsumer
     {
         return new NullSubscriptionConsumer();
     }
 
-    public function purgeQueue(PsrQueue $queue): void
+    public function purgeQueue(Queue $queue): void
     {
     }
 
diff --git a/pkg/null/NullMessage.php b/pkg/null/NullMessage.php
@@ -4,9 +4,9 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrMessage;
+use Interop\Queue\Message;
 
-class NullMessage implements PsrMessage
+class NullMessage implements Message
 {
     /**
      * @var string
diff --git a/pkg/null/NullProducer.php b/pkg/null/NullProducer.php
@@ -4,26 +4,26 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrDestination;
-use Interop\Queue\PsrMessage;
-use Interop\Queue\PsrProducer;
+use Interop\Queue\Destination;
+use Interop\Queue\Message;
+use Interop\Queue\Producer;
 
-class NullProducer implements PsrProducer
+class NullProducer implements Producer
 {
     private $priority;
 
     private $timeToLive;
 
     private $deliveryDelay;
 
-    public function send(PsrDestination $destination, PsrMessage $message): void
+    public function send(Destination $destination, Message $message): void
     {
     }
 
     /**
      * @return NullProducer
      */
-    public function setDeliveryDelay(int $deliveryDelay = null): PsrProducer
+    public function setDeliveryDelay(int $deliveryDelay = null): Producer
     {
         $this->deliveryDelay = $deliveryDelay;
 
@@ -38,7 +38,7 @@ public function getDeliveryDelay(): ?int
     /**
      * @return NullProducer
      */
-    public function setPriority(int $priority = null): PsrProducer
+    public function setPriority(int $priority = null): Producer
     {
         $this->priority = $priority;
 
@@ -53,7 +53,7 @@ public function getPriority(): ?int
     /**
      * @return NullProducer
      */
-    public function setTimeToLive(int $timeToLive = null): PsrProducer
+    public function setTimeToLive(int $timeToLive = null): Producer
     {
         $this->timeToLive = $timeToLive;
 
diff --git a/pkg/null/NullQueue.php b/pkg/null/NullQueue.php
@@ -4,9 +4,9 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrQueue;
+use Interop\Queue\Queue;
 
-class NullQueue implements PsrQueue
+class NullQueue implements Queue
 {
     /**
      * @var string
diff --git a/pkg/null/NullSubscriptionConsumer.php b/pkg/null/NullSubscriptionConsumer.php
@@ -4,20 +4,20 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrConsumer;
-use Interop\Queue\PsrSubscriptionConsumer;
+use Interop\Queue\Consumer;
+use Interop\Queue\SubscriptionConsumer;
 
-class NullSubscriptionConsumer implements PsrSubscriptionConsumer
+class NullSubscriptionConsumer implements SubscriptionConsumer
 {
     public function consume(int $timeout = 0): void
     {
     }
 
-    public function subscribe(PsrConsumer $consumer, callable $callback): void
+    public function subscribe(Consumer $consumer, callable $callback): void
     {
     }
 
-    public function unsubscribe(PsrConsumer $consumer): void
+    public function unsubscribe(Consumer $consumer): void
     {
     }
 
diff --git a/pkg/null/NullTopic.php b/pkg/null/NullTopic.php
@@ -2,9 +2,9 @@
 
 namespace Enqueue\Null;
 
-use Interop\Queue\PsrTopic;
+use Interop\Queue\Topic;
 
-class NullTopic implements PsrTopic
+class NullTopic implements Topic
 {
     /**
      * @var string
diff --git a/pkg/null/README.md b/pkg/null/README.md
@@ -5,7 +5,7 @@
 [![Total Downloads](https://poser.pugx.org/enqueue/null/d/total.png)](https://packagist.org/packages/enqueue/null)
 [![Latest Stable Version](https://poser.pugx.org/enqueue/null/version.png)](https://packagist.org/packages/enqueue/null)
  
-This is an implementation of PSR queue specification. It does not send messages any where and could be used as mock. Suitable in tests.
+This is an implementation of Queue Interop specification. It does not send messages any where and could be used as mock. Suitable in tests.
 
 ## Resources
 
diff --git a/pkg/null/Tests/NullConnectionFactoryTest.php b/pkg/null/Tests/NullConnectionFactoryTest.php
@@ -5,7 +5,7 @@
 use Enqueue\Null\NullConnectionFactory;
 use Enqueue\Null\NullContext;
 use Enqueue\Test\ClassExtensionTrait;
-use Interop\Queue\PsrConnectionFactory;
+use Interop\Queue\ConnectionFactory;
 use PHPUnit\Framework\TestCase;
 
 class NullConnectionFactoryTest extends TestCase
@@ -14,7 +14,7 @@ class NullConnectionFactoryTest extends TestCase
 
     public function testShouldImplementConnectionFactoryInterface()
     {
-        $this->assertClassImplements(PsrConnectionFactory::class, NullConnectionFactory::class);
+        $this->assertClassImplements(ConnectionFactory::class, NullConnectionFactory::class);
     }
 
     public function testCouldBeConstructedWithoutAnyArguments()
diff --git a/pkg/null/Tests/NullConsumerTest.php b/pkg/null/Tests/NullConsumerTest.php
@@ -6,7 +6,7 @@
 use Enqueue\Null\NullMessage;
 use Enqueue\Null\NullQueue;
 use Enqueue\Test\ClassExtensionTrait;
-use Interop\Queue\PsrConsumer;
+use Interop\Queue\Consumer;
 use PHPUnit\Framework\TestCase;
 
 class NullConsumerTest extends TestCase
@@ -15,7 +15,7 @@ class NullConsumerTest extends TestCase
 
     public function testShouldImplementMessageConsumerInterface()
     {
-        $this->assertClassImplements(PsrConsumer::class, NullConsumer::class);
+        $this->assertClassImplements(Consumer::class, NullConsumer::class);
     }
 
     public function testCouldBeConstructedWithQueueAsArgument()
diff --git a/pkg/null/Tests/NullContextTest.php b/pkg/null/Tests/NullContextTest.php
@@ -9,7 +9,7 @@
 use Enqueue\Null\NullQueue;
 use Enqueue\Null\NullTopic;
 use Enqueue\Test\ClassExtensionTrait;
-use Interop\Queue\PsrContext;
+use Interop\Queue\Context;
 use PHPUnit\Framework\TestCase;
 
 class NullContextTest extends TestCase
@@ -18,7 +18,7 @@ class NullContextTest extends TestCase
 
     public function testShouldImplementSessionInterface()
     {
-        $this->assertClassImplements(PsrContext::class, NullContext::class);
+        $this->assertClassImplements(Context::class, NullContext::class);
     }
 
     public function testCouldBeConstructedWithoutAnyArguments()
diff --git a/pkg/null/Tests/NullMessageTest.php b/pkg/null/Tests/NullMessageTest.php
@@ -4,7 +4,7 @@
 
 use Enqueue\Null\NullMessage;
 use Enqueue\Test\ClassExtensionTrait;
-use Interop\Queue\PsrMessage;
+use Interop\Queue\Message;
 use PHPUnit\Framework\TestCase;
 
 class NullMessageTest extends TestCase
@@ -13,7 +13,7 @@ class NullMessageTest extends TestCase
 
     public function testShouldImplementMessageInterface()
     {
-        $this->assertClassImplements(PsrMessage::class, NullMessage::class);
+        $this->assertClassImplements(Message::class, NullMessage::class);
     }
 
     public function testCouldBeConstructedWithoutAnyArguments()
diff --git a/pkg/null/Tests/NullProducerTest.php b/pkg/null/Tests/NullProducerTest.php
@@ -6,7 +6,7 @@
 use Enqueue\Null\NullProducer;
 use Enqueue\Null\NullTopic;
 use Enqueue\Test\ClassExtensionTrait;
-use Interop\Queue\PsrProducer;
+use Interop\Queue\Producer;
 use PHPUnit\Framework\TestCase;
 
 class NullProducerTest extends TestCase
@@ -15,7 +15,7 @@ class NullProducerTest extends TestCase
 
     public function testShouldImplementProducerInterface()
     {
-        $this->assertClassImplements(PsrProducer::class, NullProducer::class);
+        $this->assertClassImplements(Producer::class, NullProducer::class);
     }
 
     public function testCouldBeConstructedWithoutAnyArguments()
diff --git a/pkg/null/Tests/NullQueueTest.php b/pkg/null/Tests/NullQueueTest.php
diff --git a/pkg/null/Tests/NullTopicTest.php b/pkg/null/Tests/NullTopicTest.php

Original file line number	Diff line number	Diff line change
`@@ -4,15 +4,15 @@`
`4`	`4`
`5`	`5`	`namespace Enqueue\Null;`
`6`	`6`
`7`		`-use Interop\Queue\PsrConnectionFactory;`
`8`		`-use Interop\Queue\PsrContext;`
	`7`	`+use Interop\Queue\ConnectionFactory;`
	`8`	`+use Interop\Queue\Context;`
`9`	`9`
`10`		`-class NullConnectionFactory implements PsrConnectionFactory`
	`10`	`+class NullConnectionFactory implements ConnectionFactory`
`11`	`11`	`{`
`12`	`12`	`/**`
`13`	`13`	`* @return NullContext`
`14`	`14`	`*/`
`15`		`- public function createContext(): PsrContext`
	`15`	`+ public function createContext(): Context`
`16`	`16`	`{`
`17`	`17`	`return new NullContext();`
`18`	`18`	`}`
Original file line number	Diff line number	Diff line change
`@@ -4,49 +4,49 @@`
`4`	`4`
`5`	`5`	`namespace Enqueue\Null;`
`6`	`6`
`7`		`-use Interop\Queue\PsrConsumer;`
`8`		`-use Interop\Queue\PsrDestination;`
`9`		`-use Interop\Queue\PsrMessage;`
`10`		`-use Interop\Queue\PsrQueue;`
	`7`	`+use Interop\Queue\Consumer;`
	`8`	`+use Interop\Queue\Destination;`
	`9`	`+use Interop\Queue\Message;`
	`10`	`+use Interop\Queue\Queue;`
`11`	`11`
`12`		`-class NullConsumer implements PsrConsumer`
	`12`	`+class NullConsumer implements Consumer`
`13`	`13`	`{`
`14`	`14`	`/**`
`15`		`- * @var PsrDestination`
	`15`	`+ * @var Destination`
`16`	`16`	`*/`
`17`	`17`	`private $queue;`
`18`	`18`
`19`		`- public function __construct(PsrDestination $queue)`
	`19`	`+ public function __construct(Destination $queue)`
`20`	`20`	`{`
`21`	`21`	`$this->queue = $queue;`
`22`	`22`	`}`
`23`	`23`
`24`		`- public function getQueue(): PsrQueue`
	`24`	`+ public function getQueue(): Queue`
`25`	`25`	`{`
`26`	`26`	`return $this->queue;`
`27`	`27`	`}`
`28`	`28`
`29`	`29`	`/**`
`30`	`30`	`* @return NullMessage`
`31`	`31`	`*/`
`32`		`- public function receive(int $timeout = 0): ?PsrMessage`
	`32`	`+ public function receive(int $timeout = 0): ?Message`
`33`	`33`	`{`
`34`	`34`	`return null;`
`35`	`35`	`}`
`36`	`36`
`37`	`37`	`/**`
`38`	`38`	`* @return NullMessage`
`39`	`39`	`*/`
`40`		`- public function receiveNoWait(): ?PsrMessage`
	`40`	`+ public function receiveNoWait(): ?Message`
`41`	`41`	`{`
`42`	`42`	`return null;`
`43`	`43`	`}`
`44`	`44`
`45`		`- public function acknowledge(PsrMessage $message): void`
	`45`	`+ public function acknowledge(Message $message): void`
`46`	`46`	`{`
`47`	`47`	`}`
`48`	`48`
`49`		`- public function reject(PsrMessage $message, bool $requeue = false): void`
	`49`	`+ public function reject(Message $message, bool $requeue = false): void`
`50`	`50`	`{`
`51`	`51`	`}`
`52`	`52`	`}`
Original file line number	Diff line number	Diff line change
`@@ -4,21 +4,21 @@`
`4`	`4`
`5`	`5`	`namespace Enqueue\Null;`
`6`	`6`
`7`		`-use Interop\Queue\PsrConsumer;`
`8`		`-use Interop\Queue\PsrContext;`
`9`		`-use Interop\Queue\PsrDestination;`
`10`		`-use Interop\Queue\PsrMessage;`
`11`		`-use Interop\Queue\PsrProducer;`
`12`		`-use Interop\Queue\PsrQueue;`
`13`		`-use Interop\Queue\PsrSubscriptionConsumer;`
`14`		`-use Interop\Queue\PsrTopic;`
	`7`	`+use Interop\Queue\Consumer;`
	`8`	`+use Interop\Queue\Context;`
	`9`	`+use Interop\Queue\Destination;`
	`10`	`+use Interop\Queue\Message;`
	`11`	`+use Interop\Queue\Producer;`
	`12`	`+use Interop\Queue\Queue;`
	`13`	`+use Interop\Queue\SubscriptionConsumer;`
	`14`	`+use Interop\Queue\Topic;`
`15`	`15`
`16`		`-class NullContext implements PsrContext`
	`16`	`+class NullContext implements Context`
`17`	`17`	`{`
`18`	`18`	`/**`
`19`	`19`	`* @return NullMessage`
`20`	`20`	`*/`
`21`		`- public function createMessage(string $body = '', array $properties = [], array $headers = []): PsrMessage`
	`21`	`+ public function createMessage(string $body = '', array $properties = [], array $headers = []): Message`
`22`	`22`	`{`
`23`	`23`	`$message = new NullMessage();`
`24`	`24`	`$message->setBody($body);`
`@@ -31,52 +31,52 @@ public function createMessage(string $body = '', array $properties = [], array $`
`31`	`31`	`/**`
`32`	`32`	`* @return NullQueue`
`33`	`33`	`*/`
`34`		`- public function createQueue(string $name): PsrQueue`
	`34`	`+ public function createQueue(string $name): Queue`
`35`	`35`	`{`
`36`	`36`	`return new NullQueue($name);`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`/**`
`40`	`40`	`* @return NullQueue`
`41`	`41`	`*/`
`42`		`- public function createTemporaryQueue(): PsrQueue`
	`42`	`+ public function createTemporaryQueue(): Queue`
`43`	`43`	`{`
`44`	`44`	`return $this->createQueue(uniqid('', true));`
`45`	`45`	`}`
`46`	`46`
`47`	`47`	`/**`
`48`	`48`	`* @return NullTopic`
`49`	`49`	`*/`
`50`		`- public function createTopic(string $name): PsrTopic`
	`50`	`+ public function createTopic(string $name): Topic`
`51`	`51`	`{`
`52`	`52`	`return new NullTopic($name);`
`53`	`53`	`}`
`54`	`54`
`55`	`55`	`/**`
`56`	`56`	`* @return NullConsumer`
`57`	`57`	`*/`
`58`		`- public function createConsumer(PsrDestination $destination): PsrConsumer`
	`58`	`+ public function createConsumer(Destination $destination): Consumer`
`59`	`59`	`{`
`60`	`60`	`return new NullConsumer($destination);`
`61`	`61`	`}`
`62`	`62`
`63`	`63`	`/**`
`64`	`64`	`* @return NullProducer`
`65`	`65`	`*/`
`66`		`- public function createProducer(): PsrProducer`
	`66`	`+ public function createProducer(): Producer`
`67`	`67`	`{`
`68`	`68`	`return new NullProducer();`
`69`	`69`	`}`
`70`	`70`
`71`	`71`	`/**`
`72`	`72`	`* @return NullSubscriptionConsumer`
`73`	`73`	`*/`
`74`		`- public function createSubscriptionConsumer(): PsrSubscriptionConsumer`
	`74`	`+ public function createSubscriptionConsumer(): SubscriptionConsumer`
`75`	`75`	`{`
`76`	`76`	`return new NullSubscriptionConsumer();`
`77`	`77`	`}`
`78`	`78`
`79`		`- public function purgeQueue(PsrQueue $queue): void`
	`79`	`+ public function purgeQueue(Queue $queue): void`
`80`	`80`	`{`
`81`	`81`	`}`
`82`	`82`
Original file line number	Diff line number	Diff line change
`@@ -4,9 +4,9 @@`
`4`	`4`
`5`	`5`	`namespace Enqueue\Null;`
`6`	`6`
`7`		`-use Interop\Queue\PsrMessage;`
	`7`	`+use Interop\Queue\Message;`
`8`	`8`
`9`		`-class NullMessage implements PsrMessage`
	`9`	`+class NullMessage implements Message`
`10`	`10`	`{`
`11`	`11`	`/**`
`12`	`12`	`* @var string`
Original file line number	Diff line number	Diff line change
`@@ -4,20 +4,20 @@`
`4`	`4`
`5`	`5`	`namespace Enqueue\Null;`
`6`	`6`
`7`		`-use Interop\Queue\PsrConsumer;`
`8`		`-use Interop\Queue\PsrSubscriptionConsumer;`
	`7`	`+use Interop\Queue\Consumer;`
	`8`	`+use Interop\Queue\SubscriptionConsumer;`
`9`	`9`
`10`		`-class NullSubscriptionConsumer implements PsrSubscriptionConsumer`
	`10`	`+class NullSubscriptionConsumer implements SubscriptionConsumer`
`11`	`11`	`{`
`12`	`12`	`public function consume(int $timeout = 0): void`
`13`	`13`	`{`
`14`	`14`	`}`
`15`	`15`
`16`		`- public function subscribe(PsrConsumer $consumer, callable $callback): void`
	`16`	`+ public function subscribe(Consumer $consumer, callable $callback): void`
`17`	`17`	`{`
`18`	`18`	`}`
`19`	`19`
`20`		`- public function unsubscribe(PsrConsumer $consumer): void`
	`20`	`+ public function unsubscribe(Consumer $consumer): void`
`21`	`21`	`{`
`22`	`22`	`}`
`23`	`23`
Original file line number	Diff line number	Diff line change
`@@ -2,9 +2,9 @@`
`2`	`2`
`3`	`3`	`namespace Enqueue\Null;`
`4`	`4`
`5`		`-use Interop\Queue\PsrTopic;`
	`5`	`+use Interop\Queue\Topic;`
`6`	`6`
`7`		`-class NullTopic implements PsrTopic`
	`7`	`+class NullTopic implements Topic`
`8`	`8`	`{`
`9`	`9`	`/**`
`10`	`10`	`* @var string`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@`
`5`	`5`	`use Enqueue\Null\NullConnectionFactory;`
`6`	`6`	`use Enqueue\Null\NullContext;`
`7`	`7`	`use Enqueue\Test\ClassExtensionTrait;`
`8`		`-use Interop\Queue\PsrConnectionFactory;`
	`8`	`+use Interop\Queue\ConnectionFactory;`
`9`	`9`	`use PHPUnit\Framework\TestCase;`
`10`	`10`
`11`	`11`	`class NullConnectionFactoryTest extends TestCase`
`@@ -14,7 +14,7 @@ class NullConnectionFactoryTest extends TestCase`
`14`	`14`
`15`	`15`	`public function testShouldImplementConnectionFactoryInterface()`
`16`	`16`	`{`
`17`		`- $this->assertClassImplements(PsrConnectionFactory::class, NullConnectionFactory::class);`
	`17`	`+ $this->assertClassImplements(ConnectionFactory::class, NullConnectionFactory::class);`
`18`	`18`	`}`
`19`	`19`
`20`	`20`	`public function testCouldBeConstructedWithoutAnyArguments()`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,7 @@`
`6`	`6`	`use Enqueue\Null\NullMessage;`
`7`	`7`	`use Enqueue\Null\NullQueue;`
`8`	`8`	`use Enqueue\Test\ClassExtensionTrait;`
`9`		`-use Interop\Queue\PsrConsumer;`
	`9`	`+use Interop\Queue\Consumer;`
`10`	`10`	`use PHPUnit\Framework\TestCase;`
`11`	`11`
`12`	`12`	`class NullConsumerTest extends TestCase`
`@@ -15,7 +15,7 @@ class NullConsumerTest extends TestCase`
`15`	`15`
`16`	`16`	`public function testShouldImplementMessageConsumerInterface()`
`17`	`17`	`{`
`18`		`- $this->assertClassImplements(PsrConsumer::class, NullConsumer::class);`
	`18`	`+ $this->assertClassImplements(Consumer::class, NullConsumer::class);`
`19`	`19`	`}`
`20`	`20`
`21`	`21`	`public function testCouldBeConstructedWithQueueAsArgument()`
Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,7 @@`
`9`	`9`	`use Enqueue\Null\NullQueue;`
`10`	`10`	`use Enqueue\Null\NullTopic;`
`11`	`11`	`use Enqueue\Test\ClassExtensionTrait;`
`12`		`-use Interop\Queue\PsrContext;`
	`12`	`+use Interop\Queue\Context;`
`13`	`13`	`use PHPUnit\Framework\TestCase;`
`14`	`14`
`15`	`15`	`class NullContextTest extends TestCase`
`@@ -18,7 +18,7 @@ class NullContextTest extends TestCase`
`18`	`18`
`19`	`19`	`public function testShouldImplementSessionInterface()`
`20`	`20`	`{`
`21`		`- $this->assertClassImplements(PsrContext::class, NullContext::class);`
	`21`	`+ $this->assertClassImplements(Context::class, NullContext::class);`
`22`	`22`	`}`
`23`	`23`
`24`	`24`	`public function testCouldBeConstructedWithoutAnyArguments()`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@`
`4`	`4`
`5`	`5`	`use Enqueue\Null\NullMessage;`
`6`	`6`	`use Enqueue\Test\ClassExtensionTrait;`
`7`		`-use Interop\Queue\PsrMessage;`
	`7`	`+use Interop\Queue\Message;`
`8`	`8`	`use PHPUnit\Framework\TestCase;`
`9`	`9`
`10`	`10`	`class NullMessageTest extends TestCase`
`@@ -13,7 +13,7 @@ class NullMessageTest extends TestCase`
`13`	`13`
`14`	`14`	`public function testShouldImplementMessageInterface()`
`15`	`15`	`{`
`16`		`- $this->assertClassImplements(PsrMessage::class, NullMessage::class);`
	`16`	`+ $this->assertClassImplements(Message::class, NullMessage::class);`
`17`	`17`	`}`
`18`	`18`
`19`	`19`	`public function testCouldBeConstructedWithoutAnyArguments()`