Try to fix alibaba#4573,alibaba#4629. Jraft leader status check error.

KomachiSion · Mar 17, 2021 · 87ca61b · 87ca61b
1 parent 4029d32
commit 87ca61b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...java/com/alibaba/nacos/naming/consistency/persistent/impl/PersistentServiceProcessor.java b/...java/com/alibaba/nacos/naming/consistency/persistent/impl/PersistentServiceProcessor.java
@@ -65,10 +65,10 @@ public PersistentServiceProcessor(ProtocolManager protocolManager, ClusterVersio
     @Override
     public void afterConstruct() {
         super.afterConstruct();
-        this.protocol.addRequestProcessors(Collections.singletonList(this));
         this.protocol.protocolMetaData()
                 .subscribe(Constants.NAMING_PERSISTENT_SERVICE_GROUP, MetadataKey.LEADER_META_DATA,
                         (o, arg) -> hasLeader = StringUtils.isNotBlank(String.valueOf(arg)));
+        this.protocol.addRequestProcessors(Collections.singletonList(this));
         // If you choose to use the new RAFT protocol directly, there will be no compatible logical execution
         if (EnvUtil.getProperty(Constants.NACOS_NAMING_USE_NEW_RAFT_FIRST, Boolean.class, false)) {
             NotifyCenter.registerSubscriber(notifier);