dispatch

src/emqttd_sm.erl

@@ -102,7 +102,7 @@ unreg_session(ClientId) ->
 
 dispatch(ClientId, Topic, Msg) ->
     try ets:lookup_element(mqtt_local_session, ClientId, 2) of
-        Pid -> Pid ! {deliver, Topic, Msg}
+        Pid -> Pid ! {dispatch, Topic, Msg}
     catch
         error:badarg -> io:format("Session Not Found: ~p~n", [ClientId]), ok %%TODO: How??
     end.