From c194e82807809aef3fa99593c8a6c21f897e249d Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Mon, 9 Apr 2018 14:31:34 +0800 Subject: [PATCH] Export dispatch/2, dispatch/3 for RPC --- src/emqx_broker.erl | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/emqx_broker.erl b/src/emqx_broker.erl index 7cd80a33e..cb422b9e4 100644 --- a/src/emqx_broker.erl +++ b/src/emqx_broker.erl @@ -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.