fix dispatch

2016-01-20 15:38:24 +08:00 · 2016-01-20 15:38:24 +08:00 · b5c514b39c
parent 284abc7388
commit b5c514b39c
1 changed files with 1 additions and 1 deletions
--- a/src/emqttd_bridge.erl
+++ b/src/emqttd_bridge.erl
@ -172,7 +172,7 @@ dequeue(State = #state{mqueue = MQ}) ->
        {empty, MQ1} ->
            State#state{mqueue = MQ1};
        {{value, Msg}, MQ1} ->
-            handle_info({dispatch, Msg}, State),
+            handle_info({dispatch, Msg#mqtt_message.topic, Msg}, State),
            dequeue(State#state{mqueue = MQ1})
    end.