diff options
| author | Magnus Feuer <mfeuer@jaguarlandrover.com> | 2014-12-02 15:54:45 -0800 |
|---|---|---|
| committer | Magnus Feuer <mfeuer@jaguarlandrover.com> | 2014-12-02 15:54:45 -0800 |
| commit | c6ce79ca835dfeecba079db81c2fc1a5c8e27477 (patch) | |
| tree | e19176c3c1e3d306d83ff8121012d870a50dcf4a | |
| parent | 9ccdaba11ac134a96206d183248b5d66c2424d0e (diff) | |
| download | rvi_core-c6ce79ca835dfeecba079db81c2fc1a5c8e27477.tar.gz | |
Modified to accept and dispatch incoming native calls from RVI node such as services_available and and services_unavailable
| -rw-r--r-- | big_data_demo/rvi_json_rpc_server.py | 3 | ||||
| -rw-r--r-- | hvac_demo/rvi_json_rpc_server.py | 5 | ||||
| -rw-r--r-- | sota_demo/rvi_json_rpc_server.py | 3 |
3 files changed, 4 insertions, 7 deletions
diff --git a/big_data_demo/rvi_json_rpc_server.py b/big_data_demo/rvi_json_rpc_server.py index f7e2fa5..6502415 100644 --- a/big_data_demo/rvi_json_rpc_server.py +++ b/big_data_demo/rvi_json_rpc_server.py @@ -12,7 +12,6 @@ class RVIJSONRPCServer(SimpleJSONRPCServer): # Check if method is 'message', if so dispatch on # name 'service_name' instead. def _dispatch(self, method, params): - # print "dispatch:", params if method == 'message': # print "Will dispatch message to: " + params['service_name'] dict_param = {} @@ -34,4 +33,4 @@ class RVIJSONRPCServer(SimpleJSONRPCServer): return SimpleJSONRPCServer._dispatch(self, params['service_name'], dict_param) - return SimpleJSONRPCServer._dispatch(self,message, params) + return SimpleJSONRPCServer._dispatch(self,method, params) diff --git a/hvac_demo/rvi_json_rpc_server.py b/hvac_demo/rvi_json_rpc_server.py index f7e2fa5..c3b45e2 100644 --- a/hvac_demo/rvi_json_rpc_server.py +++ b/hvac_demo/rvi_json_rpc_server.py @@ -12,7 +12,6 @@ class RVIJSONRPCServer(SimpleJSONRPCServer): # Check if method is 'message', if so dispatch on # name 'service_name' instead. def _dispatch(self, method, params): - # print "dispatch:", params if method == 'message': # print "Will dispatch message to: " + params['service_name'] dict_param = {} @@ -33,5 +32,5 @@ class RVIJSONRPCServer(SimpleJSONRPCServer): # Ship the processed dispatch info upward. return SimpleJSONRPCServer._dispatch(self, params['service_name'], dict_param) - - return SimpleJSONRPCServer._dispatch(self,message, params) + + return SimpleJSONRPCServer._dispatch(self,method, params) diff --git a/sota_demo/rvi_json_rpc_server.py b/sota_demo/rvi_json_rpc_server.py index f7e2fa5..6502415 100644 --- a/sota_demo/rvi_json_rpc_server.py +++ b/sota_demo/rvi_json_rpc_server.py @@ -12,7 +12,6 @@ class RVIJSONRPCServer(SimpleJSONRPCServer): # Check if method is 'message', if so dispatch on # name 'service_name' instead. def _dispatch(self, method, params): - # print "dispatch:", params if method == 'message': # print "Will dispatch message to: " + params['service_name'] dict_param = {} @@ -34,4 +33,4 @@ class RVIJSONRPCServer(SimpleJSONRPCServer): return SimpleJSONRPCServer._dispatch(self, params['service_name'], dict_param) - return SimpleJSONRPCServer._dispatch(self,message, params) + return SimpleJSONRPCServer._dispatch(self,method, params) |