def callback(self, ch, method, properties, body):
logger.debug("Reacting on %s in %s", str(method.routing_key), self.get_subclass_name())
body = json.loads(body.decode("utf-8"))
- self.used_channel = method.routing_key.split(".")
+ try:
+ self.used_channel = method.routing_key.split(".")
+ except TypeError as e:
+ logging.error(f"{str(method.routing_key)} is of type {type(method.routing_key)}")
+ logging.exception(e)
+ self.used_channel = ["__error__"]
if self.uses_history:
self.history = self.total_history[body["to"]]