diff --git a/apps/efka/src/channel/ws_channel.erl b/apps/efka/src/channel/ws_channel.erl index 20875f3..9c9d847 100644 --- a/apps/efka/src/channel/ws_channel.erl +++ b/apps/efka/src/channel/ws_channel.erl @@ -59,6 +59,8 @@ websocket_info({topic_broadcast, Topic, Content}, State = #state{}) -> <<"params">> => #{<<"topic">> => Topic, <<"content">> => Content} }, [force_utf8])), + lager:debug("[ws_channel] will publish topic: ~p, message: ~p", [Topic, Req]), + {reply, {text, Req}, State}; %% service进程关闭