diff --git a/src/emqx_session.erl b/src/emqx_session.erl index 098d76c52..e6b9cc37c 100644 --- a/src/emqx_session.erl +++ b/src/emqx_session.erl @@ -886,7 +886,7 @@ deliver(PacketId, Msg, State) -> do_deliver(PacketId, Msg, #state{conn_pid = ConnPid, binding = local}) -> ConnPid ! {deliver, {publish, PacketId, Msg}}, ok; do_deliver(PacketId, Msg, #state{conn_pid = ConnPid, binding = remote}) -> - emqx_rpc:cast(node(ConnPid), erlang, send, [ConnPid, {deliver, {publish, PacketId, Msg}}]). + emqx_rpc:cast(node(ConnPid), erlang, send, [ConnPid, {deliver, {publish, PacketId, Msg}}]), ok. %%------------------------------------------------------------------------------ %% Awaiting ACK for QoS1/QoS2 Messages