diff --git a/src/emqttd_bridge.erl b/src/emqttd_bridge.erl
index 20c353386..4d4f1173c 100644
--- 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.