Skip to content

Commit 2445ef2

Browse files
committed
use uuid v4 to prevent collisions
1 parent 09e148c commit 2445ef2

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

‎pkg/dbal/DbalConsumerHelperTrait.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ protected function fetchMessage(array $queues, int $redeliveryDelay): ?DbalMessa
2626
}
2727

2828
$now = time();
29-
$deliveryId = Uuid::uuid1();
29+
$deliveryId = Uuid::uuid4();
3030

3131
$endAt = microtime(true) + 0.2; // add 200ms
3232

‎pkg/dbal/DbalProducer.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public function send(Destination $destination, Message $message): void
7171
}
7272

7373
$body = $message->getBody();
74-
$uuid = Uuid::uuid1();
74+
$uuid = Uuid::uuid4();
7575

7676
$publishedAt = null !== $message->getPublishedAt() ?
7777
$message->getPublishedAt() :

‎pkg/dbal/Tests/DbalConsumerTest.php‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ public function testAcknowledgeShouldThrowIfInstanceOfMessageIsInvalid()
5656

5757
public function testShouldDeleteMessageOnAcknowledge()
5858
{
59-
$deliveryId = Uuid::uuid1();
59+
$deliveryId = Uuid::uuid4();
6060

6161
$queue = new DbalDestination('queue');
6262

@@ -127,7 +127,7 @@ public function testRejectShouldThrowIfInstanceOfMessageIsInvalid()
127127

128128
public function testShouldDeleteMessageFromQueueOnReject()
129129
{
130-
$deliveryId = Uuid::uuid1();
130+
$deliveryId = Uuid::uuid4();
131131

132132
$queue = new DbalDestination('queue');
133133

0 commit comments

Comments
 (0)