From 824681afc52a1b43dfa0066010787a57aa1c3fa8 Mon Sep 17 00:00:00 2001 From: Haim Daniel Date: Mon, 15 Mar 2021 17:14:29 +0200 Subject: [PATCH] Allow consuming pickle message format for api kombu supports json as default, but pickle is popular option as well: https://docs.celeryproject.org/projects/kombu/en/stable/userguide/serialization.html --- app/leek/agent/consumer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/app/leek/agent/consumer.py b/app/leek/agent/consumer.py index cbab17c..0b0ec4c 100644 --- a/app/leek/agent/consumer.py +++ b/app/leek/agent/consumer.py @@ -103,7 +103,8 @@ def get_consumers(self, Consumer, channel): logger.info("Exchange/Queue declared and bound!") logger.info("Creating consumer...") - consumer = Consumer(self.queue, callbacks=[self.on_message], accept=['json']) + consumer = Consumer(self.queue, callbacks=[self.on_message], + accept=['json', 'application/x-python-serialize']) logger.info("Consumer created!") return [consumer]