use Predis\ClientInterface not a Predis\Client

src/Queue/Pull/PredisPullEventQueue.php

@@ -12,13 +12,13 @@
 
 use GpsLab\Domain\Event\Event;
 use GpsLab\Domain\Event\Queue\Serializer\Serializer;
-use Predis\Client;
+use Predis\ClientInterface;
 use Psr\Log\LoggerInterface;
 
 class PredisPullEventQueue implements PullEventQueue
 {
     /**
-     * @var Client
+     * @var ClientInterface
      */
     private $client;
 
@@ -38,12 +38,12 @@ class PredisPullEventQueue implements PullEventQueue
     private $queue_name = '';
 
     /**
-     * @param Client          $client
+     * @param ClientInterface $client
      * @param Serializer      $serializer
      * @param LoggerInterface $logger
      * @param string          $queue_name
      */
-    public function __construct(Client $client, Serializer $serializer, LoggerInterface $logger, $queue_name)
+    public function __construct(ClientInterface $client, Serializer $serializer, LoggerInterface $logger, $queue_name)
     {
         $this->client = $client;
         $this->serializer = $serializer;

tests/Queue/Pull/PredisPullEventQueueTest.php

@@ -14,13 +14,13 @@
 use GpsLab\Domain\Event\Queue\Serializer\Serializer;
 use GpsLab\Domain\Event\Tests\Fixture\PurchaseOrderCompletedEvent;
 use GpsLab\Domain\Event\Tests\Fixture\PurchaseOrderCreatedEvent;
-use Predis\Client;
+use Predis\ClientInterface;
 use Psr\Log\LoggerInterface;
 
 class PredisPullEventQueueTest extends \PHPUnit_Framework_TestCase
 {
     /**
-     * @var \PHPUnit_Framework_MockObject_MockObject|Client
+     * @var \PHPUnit_Framework_MockObject_MockObject|ClientInterface
      */
     private $client;
 
@@ -46,7 +46,7 @@ class PredisPullEventQueueTest extends \PHPUnit_Framework_TestCase
 
     protected function setUp()
     {
-        $this->client = $this->getMock(Client::class);
+        $this->client = $this->getMock(ClientInterface::class);
         $this->serializer = $this->getMock(Serializer::class);
         $this->logger = $this->getMock(LoggerInterface::class);
         $this->queue = new PredisPullEventQueue($this->client, $this->serializer, $this->logger, $this->queue_name);