fix ci check error

xwm1992 · Aug 29, 2023 · 1f85f13 · 1f85f13
1 parent 78b3d58
commit 1f85f13
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 12 deletions.
diff --git a/.../src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfiguration.java b/.../src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfiguration.java
@@ -56,17 +56,17 @@ public class EventMeshGrpcConfiguration extends CommonConfiguration {
     @ConfigFiled(field = "clientmanage.threads.num")
     private int eventMeshServerSubscribeMsgThreadNum = 4;
 
-    @ConfigFiled(field = "registry.threads.num")
-    private int eventMeshServerRegistryThreadNum = 10;
+    @ConfigFiled(field = "metaStorage.threads.num")
+    private int eventMeshServerMetaStorageThreadNum = 10;
 
     @ConfigFiled(field = "admin.threads.num")
     private int eventMeshServerAdminThreadNum = 2;
 
     @ConfigFiled(field = "retry.threads.num")
     private int eventMeshServerRetryThreadNum = 2;
 
-    @ConfigFiled(field = "pull.registry.interval")
-    private int eventMeshServerPullRegistryInterval = 30000;
+    @ConfigFiled(field = "pull.metaStorage.interval")
+    private int eventMeshServerPullMetaStorageInterval = 30000;
 
     @ConfigFiled(field = "async.accumulation.threshold")
     private int eventMeshServerAsyncAccumulationThreshold = 1000;

diff --git a/.../src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfiguration.java b/.../src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfiguration.java
@@ -60,8 +60,8 @@ public class EventMeshHTTPConfiguration extends CommonConfiguration {
     @ConfigFiled(field = "clientmanage.threads.num")
     private int eventMeshServerClientManageThreadNum = 4;
 
-    @ConfigFiled(field = "registry.threads.num")
-    private int eventMeshServerRegistryThreadNum = 10;
+    @ConfigFiled(field = "metaStorage.threads.num")
+    private int eventMeshServerMetaStorageThreadNum = 10;
 
     @ConfigFiled(field = "admin.threads.num")
     private int eventMeshServerAdminThreadNum = 2;
@@ -72,8 +72,8 @@ public class EventMeshHTTPConfiguration extends CommonConfiguration {
     @ConfigFiled(field = "")
     private int eventMeshServerWebhookThreadNum = 4;
 
-    @ConfigFiled(field = "pull.registry.interval")
-    private int eventMeshServerPullRegistryInterval = 30000;
+    @ConfigFiled(field = "pull.metaStorage.interval")
+    private int eventMeshServerPullMetaStorageInterval = 30000;
 
     @ConfigFiled(field = "async.accumulation.threshold")
     private int eventMeshServerAsyncAccumulationThreshold = 1000;

diff --git a/.../test/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfigurationTest.java b/.../test/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfigurationTest.java
@@ -49,10 +49,10 @@ private void assertGrpcConfig(EventMeshGrpcConfiguration config) {
         Assert.assertEquals(4816, config.getEventMeshServerPushMsgThreadNum());
         Assert.assertEquals(5816, config.getEventMeshServerReplyMsgThreadNum());
         Assert.assertEquals(6816, config.getEventMeshServerSubscribeMsgThreadNum());
-        Assert.assertEquals(7816, config.getEventMeshServerRegistryThreadNum());
+        Assert.assertEquals(7816, config.getEventMeshServerMetaStorageThreadNum());
         Assert.assertEquals(8816, config.getEventMeshServerAdminThreadNum());
         Assert.assertEquals(9816, config.getEventMeshServerRetryThreadNum());
-        Assert.assertEquals(11816, config.getEventMeshServerPullRegistryInterval());
+        Assert.assertEquals(11816, config.getEventMeshServerPullMetaStorageInterval());
         Assert.assertEquals(12816, config.getEventMeshServerAsyncAccumulationThreshold());
         Assert.assertEquals(13816, config.getEventMeshServerRetryBlockQueueSize());
         Assert.assertEquals(14816, config.getEventMeshServerBatchBlockQueueSize());

diff --git a/.../test/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfigurationTest.java b/.../test/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfigurationTest.java
@@ -52,11 +52,11 @@ private void assertHTTPConfig(EventMeshHTTPConfiguration config) throws AddressS
         Assert.assertEquals(4816, config.getEventMeshServerPushMsgThreadNum());
         Assert.assertEquals(5816, config.getEventMeshServerReplyMsgThreadNum());
         Assert.assertEquals(6816, config.getEventMeshServerClientManageThreadNum());
-        Assert.assertEquals(7816, config.getEventMeshServerRegistryThreadNum());
+        Assert.assertEquals(7816, config.getEventMeshServerMetaStorageThreadNum());
         Assert.assertEquals(8816, config.getEventMeshServerAdminThreadNum());
 
         Assert.assertEquals(9816, config.getEventMeshServerRetryThreadNum());
-        Assert.assertEquals(11816, config.getEventMeshServerPullRegistryInterval());
+        Assert.assertEquals(11816, config.getEventMeshServerPullMetaStorageInterval());
         Assert.assertEquals(12816, config.getEventMeshServerAsyncAccumulationThreshold());
         Assert.assertEquals(13816, config.getEventMeshServerRetryBlockQSize());
         Assert.assertEquals(14816, config.getEventMeshServerBatchBlockQSize());