diff --git a/apps/emqttd/src/emqttd_event.erl b/apps/emqttd/src/emqttd_event.erl index 350b46b2f..e226de5de 100644 --- a/apps/emqttd/src/emqttd_event.erl +++ b/apps/emqttd/src/emqttd_event.erl @@ -73,6 +73,10 @@ handle_event({connected, ClientId, Params}, State = #state{systop = SysTop}) -> emqttd_pubsub:publish(event, Msg), {ok, State}; +%%TODO: Protect from undefined clientId... +handle_event({disconnected, undefined, Reason}, State = #state{systop = SysTop}) -> + {ok, State}; + handle_event({disconnected, ClientId, Reason}, State = #state{systop = SysTop}) -> Topic = <>, Msg = #mqtt_message{topic = Topic, payload = payload(disconnected, Reason)},