diff --git a/opt/ahenk/base/model/Plugin.py b/opt/ahenk/base/model/Plugin.py
index 1af27f4..1b0ab85 100644
--- a/opt/ahenk/base/model/Plugin.py
+++ b/opt/ahenk/base/model/Plugin.py
@@ -8,7 +8,7 @@ class Plugin(object):
     """docstring for Plugin"""
 
     def __init__(self, message):
-        self.plugin = message
+        self.plugin = message['plugin']
 
     @property
     def id(self):
diff --git a/opt/ahenk/base/model/Task.py b/opt/ahenk/base/model/Task.py
index 81e810f..93c390b 100644
--- a/opt/ahenk/base/model/Task.py
+++ b/opt/ahenk/base/model/Task.py
@@ -30,7 +30,7 @@ class Task(object):
 
     @property
     def command_cls_id(self):
-        return self.task['commandClsId']
+        return json.loads(str(self.task))['commandClsId']
 
     @property
     def parameter_map(self):
@@ -42,7 +42,7 @@ class Task(object):
 
     @property
     def plugin(self):
-        return Plugin(self.task['plugin'])
+        return Plugin(json.loads(str(self.task)))
 
     @property
     def cron_str(self):