ISSUE #283

* Minor improvements.

Author: Sergio García Prado

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

@@ -48,7 +48,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

@@ -72,6 +72,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: