From 595c0f2d5ad2faddee3693cf0f3f914dbe7706b6 Mon Sep 17 00:00:00 2001
From: Feng Lee <ery.lee@gmail.com>
Date: Tue, 16 Aug 2016 15:38:38 +0800
Subject: [PATCH] dispatch

---
 src/emqttd_sm.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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.