From 8ca8e973bc4ee52a968472d1f83b43a9743b7890 Mon Sep 17 00:00:00 2001 From: Gareth Coles Date: Wed, 30 May 2018 21:08:25 +0100 Subject: Address review; remove unnecessary function --- bot/cogs/rmq.py | 10 +--------- 1 file changed, 1 insertion(+), 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}") -- cgit v1.2.3