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

Export dispatch/2, dispatch/3 for RPC

This commit is contained in:
Feng Lee 2018-04-09 14:31:34 +08:00
parent 71acf91ace
commit c194e82807
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqx_broker.erl
View File

@ -26,6 +26,8 @@
-export([publish/1, publish/2]). -export([publish/1, publish/2]).
-export([dispatch/2, dispatch/3]).
-export([subscriptions/1, subscribers/1, subscribed/2]). -export([subscriptions/1, subscribers/1, subscribed/2]).
-export([topics/0]). -export([topics/0]).
@ -128,7 +130,7 @@ route(Routes, Delivery) ->
forward(Node, To, Delivery) -> forward(Node, To, Delivery) ->
case emqx_rpc:call(Node, ?BROKER, dispatch, [To, Delivery]) of case emqx_rpc:call(Node, ?BROKER, dispatch, [To, Delivery]) of
{badrpc, Reason} -> {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; Delivery;
Delivery1 -> Delivery1 Delivery1 -> Delivery1
end. end.