diff --git a/src/appMain/sample_policy_manager.py b/src/appMain/sample_policy_manager.py
index 542aa5339b6..75a04685ed0 100644
--- a/src/appMain/sample_policy_manager.py
+++ b/src/appMain/sample_policy_manager.py
@@ -154,7 +154,11 @@ def on_message(self, data):
             print('\033[31;1mMissing fileName parameter: %s\033[0m' % str(json_data))
             return
 
-        self.write_message(self.handle_func(json_data, self.encryption, self.add_http_header))
+        msg = {
+            "requestType": json_data['requestType'],
+            "data": self.handle_func(json_data, self.encryption, self.add_http_header) 
+        }
+        self.write_message(msg)
 
     def on_close(self):
         print ("Connection Closed\n")