From 21dc9d53c4184125b14ec9c2738537a1ae9823f9 Mon Sep 17 00:00:00 2001
From: monkeyDluffy6017 <375636559@qq.com>
Date: Tue, 16 Aug 2022 13:51:22 +0800
Subject: [PATCH] chore: remove useless judge in pubsub init (#7686)

---
 apisix/core/pubsub.lua | 15 +++++----------
 1 file changed, 5 insertions(+), 10 deletions(-)

diff --git a/apisix/core/pubsub.lua b/apisix/core/pubsub.lua
index 798153a5060e..7d67fee3e498 100644
--- a/apisix/core/pubsub.lua
+++ b/apisix/core/pubsub.lua
@@ -42,16 +42,11 @@ local function init_pb_state()
     -- initialize protoc compiler
     protoc.reload()
     local pubsub_protoc = protoc.new()
-
-    -- compile the protobuf file on initial load module
-    -- ensure that each worker is loaded once
-    if not pubsub_protoc.loaded["pubsub.proto"] then
-        pubsub_protoc:addpath("apisix/include/apisix/model")
-        local ok, err = pcall(pubsub_protoc.loadfile, pubsub_protoc, "pubsub.proto")
-        if not ok then
-            pubsub_protoc:reset()
-            return "failed to load pubsub protocol: " .. err
-        end
+    pubsub_protoc:addpath("apisix/include/apisix/model")
+    local ok, err = pcall(pubsub_protoc.loadfile, pubsub_protoc, "pubsub.proto")
+    if not ok then
+        pubsub_protoc:reset()
+        return "failed to load pubsub protocol: " .. err
     end
 
     pb_state = pb.state(nil)