From 998684fc4e1d359e525409272788597b908910f8 Mon Sep 17 00:00:00 2001 From: HeeeJianBo Date: Thu, 21 Mar 2019 16:56:03 +0800 Subject: [PATCH] Fix badmatch error in the batch_process of session --- src/emqx_session.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqx_session.erl b/src/emqx_session.erl index ad88190cb..8be299ced 100644 --- a/src/emqx_session.erl +++ b/src/emqx_session.erl @@ -390,7 +390,7 @@ deliver_fun(ConnPid) when node(ConnPid) == node() -> deliver_fun(ConnPid) -> Node = node(ConnPid), fun(Packet) -> - emqx_rpc:cast(Node, erlang, send, [ConnPid, {deliver, Packet}]) + true = emqx_rpc:cast(Node, erlang, send, [ConnPid, {deliver, Packet}]), ok end. handle_call(info, _From, State) -> @@ -1120,4 +1120,4 @@ do_subscribe(ClientId, Username, Topic, SubOpts, SubMap) -> emqx_broker:subscribe(Topic, ClientId, SubOpts), ok = emqx_hooks:run('session.subscribed', [#{client_id => ClientId, username => Username}, Topic, SubOpts#{first => true}]), maps:put(Topic, SubOpts, SubMap) - end. \ No newline at end of file + end.