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.