- Connect to port specified in config.

issue #283

Author: albamig

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

@@ -62,7 +62,7 @@ def _from_config(cls, config: MinosConfig, **kwargs) -> RabbitMQBrokerPublisher:
 
     async def _setup(self) -> None:
         await super()._setup()
-        self.connection = await connect(f"amqp://guest:guest@{self.broker_host}/")
+        self.connection = await connect(f"amqp://guest:guest@{self.broker_host}:{self.broker_port}/")
 
     async def _destroy(self) -> None:
         await self.connection.close()

packages/plugins/minos-broker-rabbitmq/tests/test_config.yml

@@ -23,7 +23,7 @@ snapshot:
     port: 5432
 broker:
   host: localhost
-  port: 9092
+  port: 5672
   queue:
     database: order_db
     user: minos

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

@@ -23,7 +23,7 @@ async def test_integration(self):
         async with RabbitMQBrokerPublisher.from_config(CONFIG_FILE_PATH) as publisher:
             await publisher.send(message)
 
-        async with RabbitMQBrokerSubscriber.from_config(CONFIG_FILE_PATH, topics={"foo", "bar"}) as subscriber:
+        async with RabbitMQBrokerSubscriber.from_config(CONFIG_FILE_PATH, topics={"foo"}) as subscriber:
             observed = await subscriber.receive()
 
         self.assertEqual(message.content, observed.content)