Skip to content

Commit 0fba4ff

Browse files
authored
Merge pull request #4 from agorinenko/0_0_9
Исправлена ошибка публикации сообщения с ожиданием ответа
2 parents 32c948e + 2b081b1 commit 0fba4ff

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

mq_misc/publish/__main__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333

3434

3535
class SimpleReplyToConsumer(ReplyToConsumer):
36-
async def process_message(self, body: dict, raw_message: aio_pika.IncomingMessage, **kwargs) -> None:
36+
async def process_message(self, body: dict, raw_message: aio_pika.IncomingMessage, *args, **kwargs) -> None:
3737
logger.info('Response...\n%s', pprint.pformat(body))
3838

3939

setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111

1212
setuptools.setup(
1313
name="mq-misc",
14-
version="0.0.8",
14+
version="0.0.9",
1515
author="Anton Gorinenko",
1616
author_email="[email protected]",
1717
description="Utility package for working with rabbitmq",

0 commit comments

Comments
 (0)