diff --git a/kong/clustering/rpc/socket.lua b/kong/clustering/rpc/socket.lua
index a394ceeaa664..62c3c7dc6d28 100644
--- a/kong/clustering/rpc/socket.lua
+++ b/kong/clustering/rpc/socket.lua
@@ -262,9 +262,10 @@ function _M:start()
         goto continue
       end
 
-      local res, err = self.outgoing:push(results)
+      local res, err = self:push_result(results,
+                                        "[rpc] unable to push RPC call result: ")
       if not res then
-        return nil, "[rpc] unable to push RPC call result: " .. err
+        return nil, err
       end
 
       ::continue::