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

This commit is contained in:
Feng Lee 2018-04-09 14:32:58 +08:00
commit bcdcb30af5
1 changed files with 3 additions and 1 deletions

View File

@ -26,6 +26,8 @@
-export([publish/1, publish/2]).
-export([dispatch/2, dispatch/3]).
-export([subscriptions/1, subscribers/1, subscribed/2]).
-export([topics/0]).
@ -128,7 +130,7 @@ route(Routes, Delivery) ->
forward(Node, To, Delivery) ->
case emqx_rpc:call(Node, ?BROKER, dispatch, [To, Delivery]) of
{badrpc, Reason} ->
emqx_log:error("[Broker] Failed to forward msg to ~s: ~s", [Node, Reason]),
emqx_log:error("[Broker] Failed to forward msg to ~s: ~p", [Node, Reason]),
Delivery;
Delivery1 -> Delivery1
end.