src/Application/Messaging/EnqueueStoredJobsService.php 1 location
|
@@ 76-78 (lines=3) @@
|
| 73 |
|
if (method_exists($message, 'setMessageDeduplicationId')) { |
| 74 |
|
$message->setMessageDeduplicationId(uniqid()); |
| 75 |
|
} |
| 76 |
|
if (method_exists($message, 'setMessageGroupId')) { |
| 77 |
|
$message->setMessageGroupId( |
| 78 |
|
is_null($storedJob->fifoGroupId()) |
| 79 |
|
? uniqid() |
| 80 |
|
: $storedJob->fifoGroupId() |
| 81 |
|
); |
src/Application/Messaging/ConsumeStoredJobService.php 1 location
|
@@ 163-165 (lines=3) @@
|
| 160 |
|
if (method_exists($message, 'setMessageDeduplicationId')) { |
| 161 |
|
$message->setMessageDeduplicationId(uniqid()); |
| 162 |
|
} |
| 163 |
|
if (method_exists($message, 'setMessageGroupId')) { |
| 164 |
|
$message->setMessageGroupId(is_null($storedJob->fifoGroupId()) ? uniqid() : $storedJob->fifoGroupId()); |
| 165 |
|
} |
| 166 |
|
$this->logger->info('Requeueing the message.', ['message' => $message->getBody()]); |
| 167 |
|
$consumer->reject($message, true); |
| 168 |
|
} |