Skip to content

Commit c285f64

Browse files
authoredNov 30, 2018
Merge pull request #665 from php-enqueue/dbal-wrong-bytes-id
[dbal] Use ordered bytes time uuid codec on message id decode.
2 parents da05a6a + 66067ad commit c285f64

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed
 

‎pkg/dbal/DbalContext.php

+5-1
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)
Please sign in to comment.