diff --git a/apps/iot/src/iot_host.erl b/apps/iot/src/iot_host.erl index b76ef09..8cc5ef6 100644 --- a/apps/iot/src/iot_host.erl +++ b/apps/iot/src/iot_host.erl @@ -178,6 +178,7 @@ handle_event({call, From}, {publish_message, ReceiverPid, CommandType, {aes, Com handle_event({call, From}, {publish_message, ReceiverPid, CommandType, Command}, _, State = #state{channel_pid = ChannelPid}) when is_binary(Command), is_pid(ChannelPid) -> %% 通过websocket发送请求 + lager:debug("[iot_host] will publish_message: ~p", [Command]), Ref = ws_channel:publish(ChannelPid, ReceiverPid, <>), {keep_state, State, [{reply, From, {ok, Ref}}]};