diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl
index 036b345aa..1af6274bf 100644
--- a/src/emqttd_pubsub.erl
+++ b/src/emqttd_pubsub.erl
@@ -69,7 +69,7 @@ route(Routes, Delivery) ->
                     {ok, DelAcc1} = route([Route], DelAcc), DelAcc1
             end, Delivery, Routes)}.
 
-delivery(Msg) -> #mqtt_delivery{message = Msg, flows = []}.
+delivery(Msg) -> #mqtt_delivery{sender = self(), message = Msg, flows = []}.
 
 %% @doc Forward message to another node...
 forward(Node, To, Delivery) ->