[BC break][dbal] Convert EnqueueClient expire to Dbal time to live and back.

Author: makasim

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

@@ -71,8 +71,12 @@ public function createTransportMessage(Message $message)
         $transportMessage->setProperties($properties);
         $transportMessage->setMessageId($message->getMessageId());
         $transportMessage->setTimestamp($message->getTimestamp());
-        $transportMessage->setDeliveryDelay($message->getDelay());
-        $transportMessage->setTimeToLive($message->getExpire());
+
+        $delay = $message->getDelay();
+        $transportMessage->setDeliveryDelay((null === $delay) ? null : ($delay * 1000));
+
+        $timeToLive = $message->getExpire();
+        $transportMessage->setTimeToLive((null === $timeToLive) ? null : ($timeToLive * 1000));
         $transportMessage->setReplyTo($message->getReplyTo());
         $transportMessage->setCorrelationId($message->getCorrelationId());
         if (array_key_exists($message->getPriority(), self::$priorityMap)) {
@@ -98,9 +102,12 @@ public function createClientMessage(PsrMessage $message)
         $clientMessage->setContentType($message->getHeader('content_type'));
         $clientMessage->setMessageId($message->getMessageId());
         $clientMessage->setTimestamp($message->getTimestamp());
+
         $timeToLive = $message->getTimeToLive();
-        $clientMessage->setExpire((null === $timeToLive) ? null : (int) round($timeToLive));
-        $clientMessage->setDelay($message->getDeliveryDelay());
+        $clientMessage->setExpire((null === $timeToLive) ? null : (int) ($timeToLive / 1000));
+
+        $delay = $message->getDeliveryDelay();
+        $clientMessage->setDelay((null === $delay) ? null : (int) ($delay / 1000));
         $clientMessage->setReplyTo($message->getReplyTo());
         $clientMessage->setCorrelationId($message->getCorrelationId());
 

Diff for: pkg/dbal/DbalConsumer.php

@@ -163,7 +163,7 @@ protected function receiveMessage()
 
             $this->dbal->commit();
 
-            if (empty($dbalMessage['time_to_live']) || $dbalMessage['time_to_live'] > time()) {
+            if (empty($dbalMessage['time_to_live']) || ($dbalMessage['time_to_live'] / 1000) > microtime(true)) {
                 return $this->convertMessage($dbalMessage);
             }
         } catch (\Exception $e) {