add strict to redis transport.

Author: makasim

Diff for: PRedis.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Predis\Client;

Diff for: RedisConnectionFactory.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\PsrConnectionFactory;

Diff for: RedisConsumer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\InvalidMessageException;

Diff for: RedisContext.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\InvalidDestinationException;

Diff for: RedisDestination.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\PsrQueue;

Diff for: RedisMessage.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\PsrMessage;

Diff for: RedisProducer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\InvalidDestinationException;

Diff for: RedisResult.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 class RedisResult

Diff for: RedisSubscriptionConsumer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\PsrConsumer;
@@ -53,7 +55,7 @@ public function consume(int $timeout = 0): void
              * @var PsrConsumer $consumer
              * @var callable    $processor
              */
-            $result = $this->context->getRedis()->brpop($currentQueueNames, $timeout || 5000);
+            $result = $this->context->getRedis()->brpop($currentQueueNames, $timeout ?: 5000);
             if ($result) {
                 $message = RedisMessage::jsonUnserialize($result->getMessage());
                 list($consumer, $callback) = $this->subscribers[$result->getKey()];

Diff for: ServerException.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Redis;
 
 use Interop\Queue\Exception;