diff options
author | 2018-05-30 21:08:25 +0100 | |
---|---|---|
committer | 2018-05-30 21:08:25 +0100 | |
commit | 8ca8e973bc4ee52a968472d1f83b43a9743b7890 (patch) | |
tree | 5af3e60f8ca0e7f1aa3a30e0749f39e03520f96c | |
parent | Address review (diff) |
Address review; remove unnecessary function
-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}") |