From e47aa6739993bda061393723dfc20dadb1b4b197 Mon Sep 17 00:00:00 2001
From: chronolaw <chrono_cpp@me.com>
Date: Sun, 22 Dec 2024 18:53:29 +0800
Subject: [PATCH] clean

---
 kong/clustering/rpc/socket.lua | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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::