diff --git a/src/emqttd_sm.erl b/src/emqttd_sm.erl
index 4b82c3434..3a978b3fd 100644
--- a/src/emqttd_sm.erl
+++ b/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.