Merge pull request #50 from cloudblue/lite-21143-fix-dead-letter-commands

LITE-21143 Fix cqrs_dead_letters commands

Author: net-free

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():

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,