From 3a43981b5193cb4785014b7a5b3e829293927fc3 Mon Sep 17 00:00:00 2001 From: BlackYps Date: Wed, 5 Jun 2024 14:25:40 +0200 Subject: [PATCH] Fix test --- tests/integration_tests/test_message_queue_service.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/integration_tests/test_message_queue_service.py b/tests/integration_tests/test_message_queue_service.py index 5b2928f..0d3ba89 100644 --- a/tests/integration_tests/test_message_queue_service.py +++ b/tests/integration_tests/test_message_queue_service.py @@ -107,7 +107,7 @@ async def test_incorrect_vhost(mocker, caplog): async def test_parse_incoming_message(mq_service, consumer): - payload = {"msg": "value"} + payload = {"msg": "test message", "another_key": "value"} exchange_name = config.EXCHANGE_NAME routing_key = "test.routing.key" delivery_mode = aio_pika.DeliveryMode.NOT_PERSISTENT @@ -116,7 +116,7 @@ async def test_parse_incoming_message(mq_service, consumer): await asyncio.sleep(0.1) - received_message = consumer.received_messages[0] + received_message = consumer.received_messages[-1] parsed_message = message_to_dict(received_message) for key, value in payload.items():