From b59a1d7547d78aefa8d526e3107387deac77d3be Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Wed, 17 Aug 2016 08:49:45 +0800
Subject: [PATCH] sender

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

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) ->