Merge pull request #516 from php-enqueue/add-declare-strict

Add declare strict

Author: makasim

bin/subtree-split

@@ -65,6 +65,7 @@ remote test git@github.com:php-enqueue/test.git
 remote async-event-dispatcher git@github.com:php-enqueue/async-event-dispatcher.git
 remote async-command git@github.com:php-enqueue/async-command.git
 remote mongodb git@github.com:php-enqueue/mongodb.git
+remote dsn git@github.com:php-enqueue/dsn.git
 
 split 'pkg/enqueue' enqueue
 split 'pkg/simple-client' simple-client
@@ -88,3 +89,4 @@ split 'pkg/test' test
 split 'pkg/async-event-dispatcher' async-event-dispatcher
 split 'pkg/async-command' async-command
 split 'pkg/mongodb' mongodb
+split 'pkg/dsn' dsn

pkg/amqp-bunny/AmqpConnectionFactory.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\AmqpBunny;
 
 use Enqueue\AmqpTools\ConnectionConfig;

pkg/amqp-bunny/AmqpConsumer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\AmqpBunny;
 
 use Bunny\Channel;

pkg/amqp-bunny/AmqpContext.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\AmqpBunny;
 
 use Bunny\Channel;
@@ -45,11 +47,6 @@ class AmqpContext implements InteropAmqpContext, DelayStrategyAware
      */
     private $config;
 
-    /**
-     * @var AmqpSubscriptionConsumer
-     */
-    private $bcSubscriptionConsumer;
-
     /**
      * Callable must return instance of \Bunny\Channel once called.
      *
@@ -330,7 +327,7 @@ public function convertMessage(Message $bunnyMessage): InteropAmqpMessage
         }
 
         $message = new AmqpMessage($bunnyMessage->content, $properties, $headers);
-        $message->setDeliveryTag($bunnyMessage->deliveryTag);
+        $message->setDeliveryTag((int) $bunnyMessage->deliveryTag);
         $message->setRedelivered($bunnyMessage->redelivered);
         $message->setRoutingKey($bunnyMessage->routingKey);
 

pkg/amqp-bunny/AmqpProducer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\AmqpBunny;
 
 use Bunny\Channel;
@@ -136,7 +138,7 @@ private function doSend(InteropAmqpDestination $destination, InteropAmqpMessage
         $amqpProperties = $message->getHeaders();
 
         if (array_key_exists('timestamp', $amqpProperties) && null !== $amqpProperties['timestamp']) {
-            $amqpProperties['timestamp'] = \DateTime::createFromFormat('U', $amqpProperties['timestamp']);
+            $amqpProperties['timestamp'] = \DateTime::createFromFormat('U', (string) $amqpProperties['timestamp']);
         }
 
         if ($appProperties = $message->getProperties()) {

pkg/amqp-bunny/AmqpSubscriptionConsumer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\AmqpBunny;
 
 use Bunny\Channel;

pkg/amqp-bunny/BunnyClient.php

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

pkg/amqp-bunny/Tests/AmqpConsumerTest.php

@@ -68,7 +68,7 @@ public function testOnAcknowledgeShouldAcknowledgeMessage()
             ->method('ack')
             ->with($this->isInstanceOf(Message::class))
             ->willReturnCallback(function (Message $message) {
-                $this->assertSame('theDeliveryTag', $message->deliveryTag);
+                $this->assertSame(145, $message->deliveryTag);
             });
 
         $context = $this->createContextMock();
@@ -81,7 +81,7 @@ public function testOnAcknowledgeShouldAcknowledgeMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('theDeliveryTag');
+        $message->setDeliveryTag(145);
 
         $consumer->acknowledge($message);
     }
@@ -94,7 +94,7 @@ public function testOnRejectShouldRejectMessage()
             ->method('reject')
             ->with($this->isInstanceOf(Message::class), false)
             ->willReturnCallback(function (Message $message) {
-                $this->assertSame('theDeliveryTag', $message->deliveryTag);
+                $this->assertSame(167, $message->deliveryTag);
             });
 
         $context = $this->createContextMock();
@@ -107,7 +107,7 @@ public function testOnRejectShouldRejectMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('theDeliveryTag');
+        $message->setDeliveryTag(167);
 
         $consumer->reject($message, false);
     }
@@ -120,7 +120,7 @@ public function testOnRejectShouldRequeueMessage()
             ->method('reject')
             ->with($this->isInstanceOf(Message::class), true)
             ->willReturnCallback(function (Message $message) {
-                $this->assertSame('theDeliveryTag', $message->deliveryTag);
+                $this->assertSame(178, $message->deliveryTag);
             });
 
         $context = $this->createContextMock();
@@ -133,7 +133,7 @@ public function testOnRejectShouldRequeueMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('theDeliveryTag');
+        $message->setDeliveryTag(178);
 
         $consumer->reject($message, true);
     }

pkg/amqp-lib/AmqpConnectionFactory.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\AmqpLib;
 
 use Enqueue\AmqpTools\ConnectionConfig;

pkg/amqp-lib/AmqpConsumer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\AmqpLib;
 
 use Interop\Amqp\AmqpConsumer as InteropAmqpConsumer;