Merge remote-tracking branch 'origin/283-create-rabbitmq-plugin' into 283-create-rabbitmq-plugin

Author: albamig

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

@@ -58,7 +58,9 @@ async def _setup(self) -> None:
         self.channel = await self.connection.channel()
 
     async def _destroy(self) -> None:
+        await self.channel.close()
         await self.connection.close()
+        await super()._destroy()
 
     async def _send(self, message: BrokerMessage) -> None:
         await self.channel.default_exchange.publish(Message(message.avro_bytes), routing_key=message.topic)

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

@@ -76,6 +76,7 @@ async def _setup(self) -> None:
     async def _destroy(self) -> None:
         await self._stop_task()
         await self.connection.close()
+        await super()._destroy()
 
     async def _start_task(self):
         if self._run_task is None: