diff options
-rw-r--r-- | bot/cogs/rmq.py | 10 |
1 files changed, 1 insertions, 9 deletions
diff --git a/bot/cogs/rmq.py b/bot/cogs/rmq.py index 13cc7e8c2..f6cf7332b 100644 --- a/bot/cogs/rmq.py +++ b/bot/cogs/rmq.py @@ -4,7 +4,7 @@ import logging import aio_pika from discord.ext.commands import AutoShardedBot -from bot.constants import RabbitMQ, Channels +from bot.constants import Channels, RabbitMQ log = logging.getLogger(__name__) @@ -37,14 +37,6 @@ class RMQ: with message.process(): await self.handle_message(message, message.body.decode()) - async def send_message(self, data): - await self.channel.default_exchange.publish( - aio_pika.Message( - body=data.encode() - ), - routing_key=self.queue.name - ) - async def handle_message(self, message, data): log.debug(f"Message: {message}") log.debug(f"Data: {data}") |