diff options
| author | Ulf Wiger <ulf@feuerlabs.com> | 2016-01-08 05:51:41 -0800 |
|---|---|---|
| committer | Ulf Wiger <ulf@feuerlabs.com> | 2016-01-08 05:51:41 -0800 |
| commit | 986dc5b0b94deb0bfd6fc4f8324835375fde7a04 (patch) | |
| tree | b8d95990cd49df898771b994e058baeb649201c3 /components | |
| parent | bfaed8bbbb2687473d83fb86a8cd870b189f029e (diff) | |
| download | rvi_core-986dc5b0b94deb0bfd6fc4f8324835375fde7a04.tar.gz | |
type error in services_unavailable dispatch
Diffstat (limited to 'components')
| -rw-r--r-- | components/service_edge/src/service_edge_rpc.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/components/service_edge/src/service_edge_rpc.erl b/components/service_edge/src/service_edge_rpc.erl index 7d40c59..f8b430f 100644 --- a/components/service_edge/src/service_edge_rpc.erl +++ b/components/service_edge/src/service_edge_rpc.erl @@ -602,7 +602,7 @@ json_rpc_notification(Method, Parameters) -> {<<"params">>, Parameters} ]). -dispatch_to_local_service([ $w, $s, $: | WSPidStr], services_available, +dispatch_to_local_service("ws:" ++ WSPidStr, services_available, [{<<"services">>, Services}] ) -> ?info("service_edge:dispatch_to_local_service(service_available, websock, ~p): ~p", [ WSPidStr, Services]), @@ -612,8 +612,8 @@ dispatch_to_local_service([ $w, $s, $: | WSPidStr], services_available, %% No reply ok; -dispatch_to_local_service([ $w, $s, $: | WSPidStr], services_unavailable, - [{services, Services}] ) -> +dispatch_to_local_service("ws:" ++ WSPidStr, services_unavailable, + [{<<"services">>, Services}] ) -> ?info("service_edge:dispatch_to_local_service(service_unavailable, websock, ~p): ~p", [ WSPidStr, Services]), @@ -632,7 +632,7 @@ dispatch_to_local_service([ $w, $s, $: | WSPidStr], services_unavailable, %% ?debug("service_edge:dispatch_to_local_service(message, websock): Done"), %% ok; -dispatch_to_local_service([ $w, $s, $: | WSPidStr], message, +dispatch_to_local_service("ws:" ++ WSPidStr, message, [{ <<"service_name">>, SvcName}, { <<"parameters">>, Args}]) -> ?info("service_edge:dispatch_to_local_service(message/alt, websock): ~p", [Args]), @@ -644,7 +644,7 @@ dispatch_to_local_service([ $w, $s, $: | WSPidStr], message, ?debug("service_edge:dispatch_to_local_service(message, websock): Done"), ok; -dispatch_to_local_service([ $w, $s, $: | _WSPidStr], message, Other) -> +dispatch_to_local_service("ws:" ++ _WSPidStr, message, Other) -> ?warning("service_edge:dispatch_to_local_service(message/alt, websock): UNKNOWN: ~p", [Other]), ok; |