Skip to content

Commit 5615d56

Browse files
committed
redis new implementation
1 parent 3681e17 commit 5615d56

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

pkg/redis/RedisProducer.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,12 +4,12 @@
44

55
namespace Enqueue\Redis;
66

7-
use Enqueue\Util\UUID;
87
use Interop\Queue\Destination;
98
use Interop\Queue\Exception\InvalidDestinationException;
109
use Interop\Queue\Exception\InvalidMessageException;
1110
use Interop\Queue\Message;
1211
use Interop\Queue\Producer;
12+
use Ramsey\Uuid\Uuid;
1313

1414
class RedisProducer implements Producer
1515
{
@@ -45,7 +45,7 @@ public function send(Destination $destination, Message $message): void
4545
InvalidDestinationException::assertDestinationInstanceOf($destination, RedisDestination::class);
4646
InvalidMessageException::assertMessageInstanceOf($message, RedisMessage::class);
4747

48-
$message->setMessageId(UUID::generate());
48+
$message->setMessageId(Uuid::uuid4()->toString());
4949
$message->setHeader('attempts', 0);
5050

5151
if (null !== $this->timeToLive && null === $message->getTimeToLive()) {

pkg/redis/composer.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,8 @@
88
"require": {
99
"php": "^7.1.3",
1010
"queue-interop/queue-interop": "0.7.x-dev",
11-
"enqueue/dsn": "0.9.x-dev"
11+
"enqueue/dsn": "0.9.x-dev",
12+
"ramsey/uuid": "^3"
1213
},
1314
"require-dev": {
1415
"phpunit/phpunit": "~5.4.0",

0 commit comments

Comments
 (0)