Skip to content

Commit 5d03ee7

Browse files
committed
SWR-20482 Server: RabbitMQ Improvements: Deduplication
1 parent 1ff003b commit 5d03ee7

File tree

2 files changed

+0
-6
lines changed

2 files changed

+0
-6
lines changed

config/rabbitmq.php

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727

2828
'deduplication' => [
2929
'enabled' => env('RABBITMQ_DEDUPLICATION_ENABLED', false),
30-
'skip_for_dlq' => env('RABBITMQ_DEDUPLICATION_SKIP_FOR_DLQ', true),
3130
'ttl' => env('RABBITMQ_DEDUPLICATION_TTL', 7200),
3231
'lock_ttl' => env('RABBITMQ_DEDUPLICATION_LOCK_TTL', 60),
3332
'connection' => [

src/Services/Deduplication/DeduplicationService.php

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
/**
99
* @phpstan-type DeduplicationConfig array{
1010
* enabled: bool,
11-
* skip_for_dlq: bool,
1211
* ttl: int,
1312
* lock_ttl: int,
1413
* connection: array{
@@ -119,10 +118,6 @@ protected function getMessageId(AMQPMessage $message, ?string $queueName = null)
119118
}
120119

121120
if (DlqDetector::isDlqMessage($message)) {
122-
if ($this->getConfig('skip_for_dlq', false)) {
123-
return null;
124-
}
125-
126121
$messageId = 'dlq:' . $messageId;
127122
}
128123

0 commit comments

Comments
 (0)