yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'emq20' of github.com:emqtt/emqttd into emq20

This commit is contained in:
Feng Lee 2016-08-17 12:35:59 +08:00
parent d72c7ad07c b59a1d7547
commit 6d5ce1f584
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqttd_pubsub.erl
View File

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