Merge pull request #499 from php-enqueue/dbal-fix-delay-time-conversion

[BC break][dbal] Fix time conversion in DbalDriver.

Author: makasim

Diff for: pkg/dbal/Client/DbalDriver.php

@@ -71,7 +71,7 @@ public function createTransportMessage(Message $message)
         $transportMessage->setProperties($properties);
         $transportMessage->setMessageId($message->getMessageId());
         $transportMessage->setTimestamp($message->getTimestamp());
-        $transportMessage->setDeliveryDelay($message->getDelay());
+        $transportMessage->setDeliveryDelay($message->getDelay() * 1000);
         $transportMessage->setReplyTo($message->getReplyTo());
         $transportMessage->setCorrelationId($message->getCorrelationId());
         if (array_key_exists($message->getPriority(), self::$priorityMap)) {
@@ -97,7 +97,7 @@ public function createClientMessage(PsrMessage $message)
         $clientMessage->setContentType($message->getHeader('content_type'));
         $clientMessage->setMessageId($message->getMessageId());
         $clientMessage->setTimestamp($message->getTimestamp());
-        $clientMessage->setDelay($message->getDeliveryDelay());
+        $clientMessage->setDelay($message->getDeliveryDelay() / 1000);
         $clientMessage->setReplyTo($message->getReplyTo());
         $clientMessage->setCorrelationId($message->getCorrelationId());
 

Diff for: pkg/dbal/Tests/Client/DbalDriverTest.php

@@ -117,7 +117,7 @@ public function testShouldConvertTransportMessageToClientMessage()
         $this->assertSame('MessageId', $clientMessage->getMessageId());
         $this->assertSame('ContentType', $clientMessage->getContentType());
         $this->assertSame(1000, $clientMessage->getTimestamp());
-        $this->assertSame(12345, $clientMessage->getDelay());
+        $this->assertSame(12.345, $clientMessage->getDelay());
 
         $this->assertNull($clientMessage->getExpire());
         $this->assertSame(MessagePriority::NORMAL, $clientMessage->getPriority());
@@ -134,6 +134,7 @@ public function testShouldConvertClientMessageToTransportMessage()
         $clientMessage->setPriority(MessagePriority::VERY_HIGH);
         $clientMessage->setMessageId('MessageId');
         $clientMessage->setTimestamp(1000);
+        $clientMessage->setDelay(23);
 
         $context = $this->createPsrContextMock();
         $context
@@ -165,6 +166,7 @@ public function testShouldConvertClientMessageToTransportMessage()
         ], $transportMessage->getProperties());
         $this->assertSame('MessageId', $transportMessage->getMessageId());
         $this->assertSame(1000, $transportMessage->getTimestamp());
+        $this->assertSame(23000, $transportMessage->getDeliveryDelay());
     }
 
     public function testShouldSendMessageToRouter()