diff --git a/app/leek/agent/consumer.py b/app/leek/agent/consumer.py index 9d9cf38..545fdef 100644 --- a/app/leek/agent/consumer.py +++ b/app/leek/agent/consumer.py @@ -124,7 +124,7 @@ def get_consumers(self, Consumer, channel): logger.info("Channel Configured...") logger.info("Creating consumer...") - consumer = Consumer(self.queue, callbacks=[self.on_message], accept=['json'], tag_prefix=self.subscription_name) + consumer = Consumer(self.queue, callbacks=[self.on_message], accept=['json', 'application/x-python-serialize'], tag_prefix=self.subscription_name) logger.info("Consumer created!") return [consumer]