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)