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

Fix badmatch error in the batch_process of session

This commit is contained in:
HeeeJianBo 2019-03-21 16:56:03 +08:00 committed by turtleDeng
parent 36927f01e7
commit 998684fc4e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqx_session.erl
View File

@ -390,7 +390,7 @@ deliver_fun(ConnPid) when node(ConnPid) == node() ->
deliver_fun(ConnPid) -> deliver_fun(ConnPid) ->
Node = node(ConnPid), Node = node(ConnPid),
fun(Packet) -> fun(Packet) ->
emqx_rpc:cast(Node, erlang, send, [ConnPid, {deliver, Packet}]) true = emqx_rpc:cast(Node, erlang, send, [ConnPid, {deliver, Packet}]), ok
end. end.
handle_call(info, _From, State) -> handle_call(info, _From, State) ->
@ -1120,4 +1120,4 @@ do_subscribe(ClientId, Username, Topic, SubOpts, SubMap) ->
emqx_broker:subscribe(Topic, ClientId, SubOpts), emqx_broker:subscribe(Topic, ClientId, SubOpts),
ok = emqx_hooks:run('session.subscribed', [#{client_id => ClientId, username => Username}, Topic, SubOpts#{first => true}]), ok = emqx_hooks:run('session.subscribed', [#{client_id => ClientId, username => Username}, Topic, SubOpts#{first => true}]),
maps:put(Topic, SubOpts, SubMap) maps:put(Topic, SubOpts, SubMap)
end. end.