diff options
| author | Ulf Wiger <ulf@feuerlabs.com> | 2016-03-15 15:29:04 -0700 |
|---|---|---|
| committer | Ulf Wiger <ulf@feuerlabs.com> | 2016-03-15 15:29:04 -0700 |
| commit | c69df631f683c99e8a322a8729bc67d94a355927 (patch) | |
| tree | 13b94188dd71623e1697c5ef023b250b36ae7545 /components/proto_msgpack/src/proto_msgpack_rpc.erl | |
| parent | 9ec2ee22a28a273ad1ebf7d08b6938f9861551e8 (diff) | |
| download | rvi_core-c69df631f683c99e8a322a8729bc67d94a355927.tar.gz | |
fix type errors in JSON-RPC entry points
Diffstat (limited to 'components/proto_msgpack/src/proto_msgpack_rpc.erl')
| -rw-r--r-- | components/proto_msgpack/src/proto_msgpack_rpc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/components/proto_msgpack/src/proto_msgpack_rpc.erl b/components/proto_msgpack/src/proto_msgpack_rpc.erl index 07352eb..7035353 100644 --- a/components/proto_msgpack/src/proto_msgpack_rpc.erl +++ b/components/proto_msgpack/src/proto_msgpack_rpc.erl @@ -74,7 +74,7 @@ receive_message(CompSpec, {IP, Port}, Data) -> %% JSON-RPC entry point %% CAlled by local exo http server -handle_rpc("send_message", Args) -> +handle_rpc(<<"send_message">>, Args) -> LogId = rvi_common:get_json_log_id(Args), {ok, TID} = rvi_common:get_json_element(["transaction_id"], Args), {ok, ServiceName} = rvi_common:get_json_element(["service_name"], Args), @@ -100,7 +100,7 @@ handle_rpc(Other, _Args) -> { ok, [ { status, rvi_common:json_rpc_status(invalid_command)} ] }. -handle_notification("receive_message", Args) -> +handle_notification(<<"receive_message">>, Args) -> LogId = rvi_common:get_json_log_id(Args), {ok, Data} = rvi_common:get_json_element(["data"], Args), {ok, RemoteIP} = rvi_common:get_json_element(["remote_ip"], Args), |