Merge pull request #313 from minos-framework/restyled/283-create-rabbitmq-plugin

Restyle #283 - Create RabbitMQ plugin

Author: albamig

packages/plugins/minos-broker-rabbitmq/minos/plugins/rabbitmq/subscriber.py

@@ -13,7 +13,9 @@
 from aio_pika import (
     connect,
 )
-from aio_pika.exceptions import QueueEmpty
+from aio_pika.exceptions import (
+    QueueEmpty,
+)
 
 from minos.common import (
     Config,

packages/plugins/minos-broker-rabbitmq/tests/test_rabbitmq/test_integration.py

@@ -31,4 +31,3 @@ async def test_one_topic(self):
     async def test_empty_topic(self):
         async with RabbitMQBrokerSubscriber.from_config(CONFIG_FILE_PATH, topics={"empty_topic"}) as subscriber:
             observed = await subscriber.receive()
-