check payload.id

Kong · Jan 20, 2025 · 8acaf96 · 8acaf96
1 parent b315d51
commit 8acaf96
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/kong/clustering/rpc/concentrator.lua b/kong/clustering/rpc/concentrator.lua
@@ -99,6 +99,16 @@ function _M:process_one_response(payload)
   assert(payload.jsonrpc == jsonrpc.VERSION)
   local payload_id = payload.id
 
+  -- may be some error message for peer
+  if not payload_id then
+    if payload.error then
+      ngx_log(ngx_ERR, "[rpc] RPC failed, code: ",
+                       payload.error.code, ", err: ",
+                       payload.error.message)
+    end
+    return
+  end
+
   -- response
   local cb = self.interest[payload_id]
   self.interest[payload_id] = nil -- edge trigger only once