From 47aca0d3a006946c00ba9b6be720f8cd16de4293 Mon Sep 17 00:00:00 2001 From: Konstantin Kulik Date: Fri, 19 Nov 2021 10:29:10 +0300 Subject: [PATCH] LITE-21143 Fix cqrs_dead_letters commands --- dj_cqrs/management/commands/cqrs_dead_letters.py | 4 ++-- tests/test_commands/test_dead_letters.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/dj_cqrs/management/commands/cqrs_dead_letters.py b/dj_cqrs/management/commands/cqrs_dead_letters.py index e12841c..d32d78a 100644 --- a/dj_cqrs/management/commands/cqrs_dead_letters.py +++ b/dj_cqrs/management/commands/cqrs_dead_letters.py @@ -48,7 +48,7 @@ def handle(self, *args, **options): self.check_transport() channel, connection = self.init_broker() - queue_name, dead_letter_queue_name = RabbitMQTransportService.get_consumer_settings() + queue_name, dead_letter_queue_name, *_ = RabbitMQTransportService.get_consumer_settings() dead_letters_queue = RabbitMQTransportService.declare_queue( channel, dead_letter_queue_name, ) @@ -80,7 +80,7 @@ def init_broker(self): host, port, creds, exchange, ) - queue_name, dead_letter_queue_name = RabbitMQTransportService.get_consumer_settings() + queue_name, dead_letter_queue_name, *_ = RabbitMQTransportService.get_consumer_settings() RabbitMQTransportService.declare_queue(channel, queue_name) RabbitMQTransportService.declare_queue(channel, dead_letter_queue_name) for cqrs_id, _ in ReplicaRegistry.models.items(): diff --git a/tests/test_commands/test_dead_letters.py b/tests/test_commands/test_dead_letters.py index 381b7bc..9d9f5a2 100644 --- a/tests/test_commands/test_dead_letters.py +++ b/tests/test_commands/test_dead_letters.py @@ -21,7 +21,7 @@ def test_dump(capsys, mocker): mocker.patch.object( RabbitMQTransport, '_get_consumer_settings', - return_value=('queue', 'dead_letters_queue'), + return_value=('queue', 'dead_letters_queue', 0), ) mocker.patch.object( RabbitMQTransport,