From 010e0d708f2fc3e75ca2cf3e597d98d61215450a Mon Sep 17 00:00:00 2001 From: schdwlk Date: Tue, 21 Apr 2020 20:30:03 +0200 Subject: [PATCH] Fixed redisconnector's currentconsumer handling --- redisconnector.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/redisconnector.py b/redisconnector.py index 30dd958..05d731e 100644 --- a/redisconnector.py +++ b/redisconnector.py @@ -48,7 +48,7 @@ class RedisConnector: Gets currently active consumer. :return: """ - return self.redisconnection.get('currentConsumer') + return json.loads(self.redisconnection.get('currentConsumer')) def set_currentconsumer(self, currentconsumer): """ @@ -56,7 +56,8 @@ class RedisConnector: :param currentconsumer: :return: """ - self.redisconnection.set('currentConsumer', currentconsumer) + json_dict = json.dumps(currentconsumer) + self.redisconnection.set('currentConsumer', json_dict) consumerlist = property(get_consumerlist, set_consumerlist) currentconsumer = property(get_currentconsumer, set_currentconsumer)