Skip to content

Commit 66067ad

Browse files
committed
[dbal] Fix ordered bytes time codec for message id on decode.
https://travis-ci.org/php-enqueue/enqueue-dev/jobs/458362777 ``` 1) Enqueue\Dbal\Tests\Functional\DbalConsumerTest::testShouldOrderMessagesWithSamePriorityByPublishedAtDate InvalidArgumentException: $bytes string should contain 16 characters. /mqdev/vendor/ramsey/uuid/src/Codec/StringCodec.php:97 /mqdev/vendor/ramsey/uuid/src/UuidFactory.php:188 /mqdev/vendor/ramsey/uuid/src/Uuid.php:632 /mqdev/pkg/dbal/DbalContext.php:155 /mqdev/pkg/dbal/DbalConsumerHelperTrait.php:82 /mqdev/pkg/dbal/DbalConsumer.php:83 /mqdev/vendor/queue-interop/queue-interop/src/Impl/ConsumerPollingTrait.php:42 /mqdev/pkg/dbal/Tests/Functional/DbalConsumerTest.php:95 ```
1 parent da05a6a commit 66067ad

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

‎pkg/dbal/DbalContext.php‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,9 @@
1717
use Interop\Queue\Queue;
1818
use Interop\Queue\SubscriptionConsumer;
1919
use Interop\Queue\Topic;
20+
use Ramsey\Uuid\Codec\OrderedTimeCodec;
2021
use Ramsey\Uuid\Uuid;
22+
use Ramsey\Uuid\UuidFactory;
2123

2224
class DbalContext implements Context
2325
{
@@ -152,7 +154,9 @@ public function convertMessage(array $arrayMessage): DbalMessage
152154
);
153155

154156
if (isset($arrayMessage['id'])) {
155-
$message->setMessageId(Uuid::fromBytes($arrayMessage['id'])->toString());
157+
$uuidCodec = new OrderedTimeCodec((new UuidFactory())->getUuidBuilder());
158+
159+
$message->setMessageId($uuidCodec->decodeBytes($arrayMessage['id'])->toString());
156160
}
157161
if (isset($arrayMessage['queue'])) {
158162
$message->setQueue($arrayMessage['queue']);

0 commit comments

Comments
 (0)