This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch eventmesh-function
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/eventmesh-function by this
push:
new 78942c4b0 [ISSUE #4931]Add Registry Module for Discovery AdminServer
78942c4b0 is described below
commit 78942c4b0d07efcdb6cda22b33a14e1116ad40fe
Author: sodaRyCN <[email protected]>
AuthorDate: Wed May 29 10:34:17 2024 +0800
[ISSUE #4931]Add Registry Module for Discovery AdminServer
---
.../registry/AbstractRegistryListener.java | 14 ---
.../org/apache/eventmesh/registry/NotifyEvent.java | 30 +++++++
.../eventmesh/registry/RegisterServerInfo.java | 13 +++
.../org/apache/eventmesh/registry/Registry.java | 76 ----------------
.../apache/eventmesh/registry/RegistryFactory.java | 28 ++++++
.../eventmesh/registry/RegistryListener.java | 2 +-
.../apache/eventmesh/registry/RegistryService.java | 1 -
.../registry/nacos/NacosDiscoveryService.java | 100 ++++++++++++++++-----
.../registry/nacos/NacosRegistryConfiguration.java | 23 ++---
.../org.apache.eventmesh.registry.RegistryService | 16 ++++
10 files changed, 177 insertions(+), 126 deletions(-)
diff --git
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/AbstractRegistryListener.java
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/AbstractRegistryListener.java
deleted file mode 100644
index f5e36677c..000000000
---
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/AbstractRegistryListener.java
+++ /dev/null
@@ -1,14 +0,0 @@
-package org.apache.eventmesh.registry;
-
-public abstract class AbstractRegistryListener<T> implements RegistryListener {
- protected abstract boolean checkType(Object data);
- @Override
- @SuppressWarnings("unchecked")
- public void onChange(Object data) {
- if (!checkType(data)) {
- return;
- }
- process((T)data);
- }
- protected abstract void process(T data);
-}
diff --git
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/NotifyEvent.java
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/NotifyEvent.java
new file mode 100644
index 000000000..7b27a2295
--- /dev/null
+++
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/NotifyEvent.java
@@ -0,0 +1,30 @@
+package org.apache.eventmesh.registry;
+
+import lombok.Getter;
+
+import java.util.List;
+
+public class NotifyEvent {
+
+ public NotifyEvent(){
+
+ }
+
+ public NotifyEvent(List<RegisterServerInfo> instances) {
+ this(instances, false);
+ }
+
+ public NotifyEvent(List<RegisterServerInfo> instances, boolean
isIncrement) {
+ this.isIncrement = isIncrement;
+ this.instances = instances;
+ }
+
+
+
+ // means whether it is an increment data
+ @Getter
+ private boolean isIncrement;
+
+ @Getter
+ private List<RegisterServerInfo> instances;
+}
diff --git
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegisterServerInfo.java
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegisterServerInfo.java
index a46b846df..5ad4f288c 100644
---
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegisterServerInfo.java
+++
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegisterServerInfo.java
@@ -38,4 +38,17 @@ public class RegisterServerInfo {
public void addMetadata(String key, String value) {
this.metadata.put(key, value);
}
+
+ public void setExtFields(Map<String, Object> extFields) {
+ if (extFields == null) {
+ this.extFields.clear();
+ return;
+ }
+
+ this.extFields = extFields;
+ }
+
+ public void addExtFields(String key, Object value) {
+ this.extFields.put(key, value);
+ }
}
diff --git
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/Registry.java
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/Registry.java
deleted file mode 100644
index 5a48f8c94..000000000
---
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/Registry.java
+++ /dev/null
@@ -1,76 +0,0 @@
-package org.apache.eventmesh.registry;
-
-import lombok.extern.slf4j.Slf4j;
-import org.apache.eventmesh.registry.exception.RegistryException;
-import org.apache.eventmesh.spi.EventMeshExtensionFactory;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-@Slf4j
-public class Registry implements RegistryService {
- private static final Map<String, Registry> META_CACHE = new HashMap<>(16);
- private RegistryService registryService;
-
- private final AtomicBoolean initFlag = new AtomicBoolean(false);
- private final AtomicBoolean shutdownFlag = new AtomicBoolean(false);
-
- public static Registry getInstance(String registryPluginType) {
- return META_CACHE.computeIfAbsent(registryPluginType,
Registry::registryBuilder);
- }
-
- private static Registry registryBuilder(String registryPluginType) {
- RegistryService registryServiceExt =
EventMeshExtensionFactory.getExtension(RegistryService.class,
registryPluginType);
- if (registryServiceExt == null) {
- String errorMsg = "can't load the metaService plugin, please
check.";
- log.error(errorMsg);
- throw new RuntimeException(errorMsg);
- }
- Registry metaStorage = new Registry();
- metaStorage.registryService = registryServiceExt;
-
- return metaStorage;
- }
-
- @Override
- public void init() throws RegistryException {
- if (initFlag.compareAndSet(false, true)) {
- return;
- }
- this.registryService.init();
- }
-
- @Override
- public void shutdown() throws RegistryException {
- if (shutdownFlag.compareAndSet(false, true)) {
- this.registryService.shutdown();
- }
- }
-
- @Override
- public void subscribe(RegistryListener registryListener, String
serviceName) {
- this.registryService.subscribe(registryListener, serviceName);
- }
-
- @Override
- public void unsubscribe(RegistryListener registryListener, String
serviceName) {
- this.registryService.unsubscribe(registryListener, serviceName);
- }
-
- @Override
- public List<RegisterServerInfo> selectInstances(QueryInstances serverInfo)
{
- return this.registryService.selectInstances(serverInfo);
- }
-
- @Override
- public boolean register(RegisterServerInfo registerInfo) throws
RegistryException {
- return this.registryService.register(registerInfo);
- }
-
- @Override
- public boolean unRegister(RegisterServerInfo unRegisterInfo) throws
RegistryException {
- return this.registryService.unRegister(unRegisterInfo);
- }
-}
diff --git
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryFactory.java
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryFactory.java
new file mode 100644
index 000000000..ff135b0b2
--- /dev/null
+++
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryFactory.java
@@ -0,0 +1,28 @@
+package org.apache.eventmesh.registry;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.eventmesh.spi.EventMeshExtensionFactory;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+public class RegistryFactory {
+ private static final Map<String, RegistryService> META_CACHE = new
HashMap<>(16);
+
+ public static RegistryService getInstance(String registryPluginType) {
+ return META_CACHE.computeIfAbsent(registryPluginType,
RegistryFactory::registryBuilder);
+ }
+
+ private static RegistryService registryBuilder(String registryPluginType) {
+ RegistryService registryServiceExt =
EventMeshExtensionFactory.getExtension(RegistryService.class,
registryPluginType);
+ if (registryServiceExt == null) {
+ String errorMsg = "can't load the registry plugin, please check.";
+ log.error(errorMsg);
+ throw new RuntimeException(errorMsg);
+ }
+ log.info("build registry plugin [{}] by type [{}] success",
registryServiceExt.getClass().getSimpleName(),
+ registryPluginType);
+ return registryServiceExt;
+ }
+}
diff --git
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryListener.java
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryListener.java
index 4f53e4b76..32d542ba2 100644
---
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryListener.java
+++
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryListener.java
@@ -1,5 +1,5 @@
package org.apache.eventmesh.registry;
public interface RegistryListener {
- void onChange(Object data);
+ void onChange(NotifyEvent event) throws Exception;
}
diff --git
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryService.java
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryService.java
index f549e136d..72536a08b 100644
---
a/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryService.java
+++
b/eventmesh-registry/eventmesh-registry-api/src/main/java/org/apache/eventmesh/registry/RegistryService.java
@@ -9,7 +9,6 @@ import java.util.List;
@EventMeshSPI(eventMeshExtensionType = EventMeshExtensionType.REGISTRY)
public interface RegistryService {
- String ConfigurationKey = "registry";
void init() throws RegistryException;
void shutdown() throws RegistryException;
diff --git
a/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosDiscoveryService.java
b/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosDiscoveryService.java
index dbb9a140c..13b75df61 100644
---
a/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosDiscoveryService.java
+++
b/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosDiscoveryService.java
@@ -4,16 +4,18 @@ import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
+import com.alibaba.nacos.api.naming.listener.AbstractEventListener;
+import com.alibaba.nacos.api.naming.listener.Event;
import com.alibaba.nacos.api.naming.listener.EventListener;
+import com.alibaba.nacos.api.naming.listener.NamingEvent;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.alibaba.nacos.api.naming.pojo.ServiceInfo;
import com.alibaba.nacos.api.naming.utils.NamingUtils;
import com.alibaba.nacos.client.naming.utils.UtilAndComs;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
-import org.apache.eventmesh.common.config.CommonConfiguration;
import org.apache.eventmesh.common.config.ConfigService;
-import org.apache.eventmesh.common.utils.ConfigurationContextUtil;
+import org.apache.eventmesh.registry.NotifyEvent;
import org.apache.eventmesh.registry.QueryInstances;
import org.apache.eventmesh.registry.RegisterServerInfo;
import org.apache.eventmesh.registry.RegistryListener;
@@ -28,6 +30,10 @@ import java.util.Map;
import java.util.Objects;
import java.util.Optional;
import java.util.Properties;
+import java.util.concurrent.Executor;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
@@ -35,9 +41,8 @@ import java.util.stream.Collectors;
@Slf4j
public class NacosDiscoveryService implements RegistryService {
- private final AtomicBoolean initFlag = new AtomicBoolean(false);
- private CommonConfiguration configuration;
+ private final AtomicBoolean initFlag = new AtomicBoolean(false);
private NacosRegistryConfiguration nacosConf;
@@ -45,18 +50,23 @@ public class NacosDiscoveryService implements
RegistryService {
private final Map<String, Map<RegistryListener, EventListener>> listeners
= new HashMap<>();
+ private static final Executor notifyExecutor = new ThreadPoolExecutor(1,
1, 60L, TimeUnit.SECONDS,
+ new LinkedBlockingQueue<>(20), r -> {
+ Thread t = new Thread(r);
+ t.setName("org.apache.eventmesh.registry.nacos.executor");
+ t.setDaemon(true);
+ return t;
+ }, new ThreadPoolExecutor.DiscardOldestPolicy()
+ );
+
private final Lock lock = new ReentrantLock();
- private static final String GROUP_NAME = "admin";
+
@Override
public void init() throws RegistryException {
if (!initFlag.compareAndSet(false, true)) {
return;
}
- configuration =
ConfigurationContextUtil.get(RegistryService.ConfigurationKey);
- if (configuration == null ) {
- throw new RegistryException("registry config instance is null");
- }
nacosConf =
ConfigService.getInstance().buildConfigInstance(NacosRegistryConfiguration.class);
if (nacosConf == null) {
log.info("nacos registry configuration is null");
@@ -73,12 +83,13 @@ public class NacosDiscoveryService implements
RegistryService {
private Properties buildProperties() {
Properties properties = new Properties();
- properties.setProperty(PropertyKeyConst.SERVER_ADDR,
configuration.getRegistryAddr());
- properties.setProperty(PropertyKeyConst.USERNAME,
configuration.getEventMeshRegistryPluginUsername());
- properties.setProperty(PropertyKeyConst.PASSWORD,
configuration.getEventMeshRegistryPluginPassword());
if (nacosConf == null) {
return properties;
}
+ properties.setProperty(PropertyKeyConst.SERVER_ADDR,
nacosConf.getRegistryAddr());
+ properties.setProperty(PropertyKeyConst.USERNAME,
nacosConf.getEventMeshRegistryPluginUsername());
+ properties.setProperty(PropertyKeyConst.PASSWORD,
nacosConf.getEventMeshRegistryPluginPassword());
+
String endpoint = nacosConf.getEndpoint();
if (Objects.nonNull(endpoint) && endpoint.contains(":")) {
int index = endpoint.indexOf(":");
@@ -87,7 +98,8 @@ public class NacosDiscoveryService implements RegistryService
{
} else {
Optional.ofNullable(endpoint).ifPresent(value ->
properties.put(PropertyKeyConst.ENDPOINT, endpoint));
String endpointPort = nacosConf.getEndpointPort();
- Optional.ofNullable(endpointPort).ifPresent(value ->
properties.put(PropertyKeyConst.ENDPOINT_PORT, endpointPort));
+ Optional.ofNullable(endpointPort).ifPresent(value ->
properties.put(PropertyKeyConst.ENDPOINT_PORT,
+ endpointPort));
}
String accessKey = nacosConf.getAccessKey();
Optional.ofNullable(accessKey).ifPresent(value ->
properties.put(PropertyKeyConst.ACCESS_KEY, accessKey));
@@ -96,7 +108,8 @@ public class NacosDiscoveryService implements
RegistryService {
String clusterName = nacosConf.getClusterName();
Optional.ofNullable(clusterName).ifPresent(value ->
properties.put(PropertyKeyConst.CLUSTER_NAME, clusterName));
String logFileName = nacosConf.getLogFileName();
- Optional.ofNullable(logFileName).ifPresent(value ->
properties.put(UtilAndComs.NACOS_NAMING_LOG_NAME, logFileName));
+ Optional.ofNullable(logFileName).ifPresent(value ->
properties.put(UtilAndComs.NACOS_NAMING_LOG_NAME,
+ logFileName));
String logLevel = nacosConf.getLogLevel();
Optional.ofNullable(logLevel).ifPresent(value ->
properties.put(UtilAndComs.NACOS_NAMING_LOG_LEVEL, logLevel));
Integer pollingThreadCount = nacosConf.getPollingThreadCount();
@@ -122,19 +135,54 @@ public class NacosDiscoveryService implements
RegistryService {
lock.lock();
try {
ServiceInfo serviceInfo = ServiceInfo.fromKey(serviceName);
- Map<RegistryListener, EventListener> eventListenerMap =
listeners.computeIfAbsent(serviceName, k -> new HashMap<>());
+ Map<RegistryListener, EventListener> eventListenerMap =
listeners.computeIfAbsent(serviceName,
+ k -> new HashMap<>());
if (eventListenerMap.containsKey(listener)) {
- log.warn("already use same listener subscribe service name {}"
,serviceName);
+ log.warn("already use same listener subscribe service name
{}", serviceName);
return;
}
- EventListener eventListener = listener::onChange;
- List<String> clusters ;
+ EventListener eventListener = new AbstractEventListener() {
+ @Override
+ public Executor getExecutor() {
+ return notifyExecutor;
+ }
+
+ @Override
+ public void onEvent(Event event) {
+ if (!(event instanceof NamingEvent)) {
+ log.warn("received notify event type isn't not as
expected");
+ return;
+ }
+ try {
+ NamingEvent namingEvent = (NamingEvent) event;
+ List<Instance> instances = namingEvent.getInstances();
+ List<RegisterServerInfo> list = new ArrayList<>();
+ if (instances != null) {
+ for (Instance instance : instances) {
+ RegisterServerInfo info = new
RegisterServerInfo();
+ info.setAddress(instance.getIp() + ":" +
instance.getPort());
+ info.setMetadata(instance.getMetadata());
+ info.setHealth(instance.isHealthy());
+ info.setServiceName(
+
ServiceInfo.getKey(NamingUtils.getGroupedName(namingEvent.getServiceName(),
+
namingEvent.getGroupName()),
+ namingEvent.getClusters()));
+ list.add(info);
+ }
+ }
+ listener.onChange(new NotifyEvent(list));
+ } catch (Exception e) {
+ log.warn("");
+ }
+ }
+ };
+ List<String> clusters;
if (serviceInfo.getClusters() == null ||
serviceInfo.getClusters().isEmpty()) {
clusters = new ArrayList<>();
} else {
clusters =
Arrays.stream(serviceInfo.getClusters().split(",")).collect(Collectors.toList());
}
-
namingService.subscribe(serviceInfo.getName(),serviceInfo.getGroupName(),
clusters, eventListener);
+ namingService.subscribe(serviceInfo.getName(),
serviceInfo.getGroupName(), clusters, eventListener);
eventListenerMap.put(listener, eventListener);
} catch (Exception e) {
log.error("subscribe service name {} fail", serviceName, e);
@@ -152,7 +200,7 @@ public class NacosDiscoveryService implements
RegistryService {
if (map == null) {
return;
}
- List<String> clusters ;
+ List<String> clusters;
if (serviceInfo.getClusters() == null ||
serviceInfo.getClusters().isEmpty()) {
clusters = new ArrayList<>();
} else {
@@ -177,14 +225,18 @@ public class NacosDiscoveryService implements
RegistryService {
if (StringUtils.isNotBlank(serviceInfo.getClusters())) {
clusters.addAll(Arrays.asList(serviceInfo.getClusters().split(",")));
}
- List<Instance> instances =
namingService.selectInstances(serviceInfo.getName(),
serviceInfo.getGroupName(), clusters, queryInstances.isHealth());
+ List<Instance> instances =
namingService.selectInstances(serviceInfo.getName(),
+ serviceInfo.getGroupName(), clusters,
+ queryInstances.isHealth());
if (instances != null) {
instances.forEach(x -> {
RegisterServerInfo instanceInfo = new RegisterServerInfo();
instanceInfo.setMetadata(x.getMetadata());
instanceInfo.setHealth(x.isHealthy());
instanceInfo.setAddress(x.getIp() + ":" + x.getPort());
-
instanceInfo.setServiceName(ServiceInfo.getKey(NamingUtils.getGroupedName(x.getServiceName(),
serviceInfo.getGroupName()), x.getClusterName()));
+ instanceInfo.setServiceName(
+
ServiceInfo.getKey(NamingUtils.getGroupedName(x.getServiceName(),
+ serviceInfo.getGroupName()),
x.getClusterName()));
list.add(instanceInfo);
});
}
@@ -228,7 +280,9 @@ public class NacosDiscoveryService implements
RegistryService {
return false;
}
ServiceInfo serviceInfo =
ServiceInfo.fromKey(eventMeshRegisterInfo.getServiceName());
- namingService.deregisterInstance(serviceInfo.getName(),
serviceInfo.getGroupName(), ipPort[0], Integer.parseInt(ipPort[1]),
serviceInfo.getClusters());
+ namingService.deregisterInstance(serviceInfo.getName(),
serviceInfo.getGroupName(), ipPort[0],
+ Integer.parseInt(ipPort[1]),
+ serviceInfo.getClusters());
return true;
} catch (Exception e) {
log.error("unregister instance service {} fail",
eventMeshRegisterInfo, e);
diff --git
a/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosRegistryConfiguration.java
b/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosRegistryConfiguration.java
index a8c473d27..ffb446edd 100644
---
a/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosRegistryConfiguration.java
+++
b/eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/NacosRegistryConfiguration.java
@@ -21,39 +21,40 @@ import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.client.naming.utils.UtilAndComs;
import lombok.Data;
import lombok.NoArgsConstructor;
+import org.apache.eventmesh.common.config.CommonConfiguration;
import org.apache.eventmesh.common.config.Config;
-import org.apache.eventmesh.common.config.ConfigFiled;
+import org.apache.eventmesh.common.config.ConfigField;
@Data
@NoArgsConstructor
@Config(prefix = "eventMesh.registry.nacos")
-public class NacosRegistryConfiguration {
+public class NacosRegistryConfiguration extends CommonConfiguration {
- @ConfigFiled(field = PropertyKeyConst.ENDPOINT)
+ @ConfigField(field = PropertyKeyConst.ENDPOINT)
private String endpoint;
- @ConfigFiled(field = PropertyKeyConst.ENDPOINT_PORT)
+ @ConfigField(field = PropertyKeyConst.ENDPOINT_PORT)
private String endpointPort;
- @ConfigFiled(field = PropertyKeyConst.ACCESS_KEY)
+ @ConfigField(field = PropertyKeyConst.ACCESS_KEY)
private String accessKey;
- @ConfigFiled(field = PropertyKeyConst.SECRET_KEY)
+ @ConfigField(field = PropertyKeyConst.SECRET_KEY)
private String secretKey;
- @ConfigFiled(field = PropertyKeyConst.CLUSTER_NAME)
+ @ConfigField(field = PropertyKeyConst.CLUSTER_NAME)
private String clusterName;
- @ConfigFiled(field = PropertyKeyConst.NAMESPACE)
+ @ConfigField(field = PropertyKeyConst.NAMESPACE)
private String namespace;
- @ConfigFiled(field = PropertyKeyConst.NAMING_POLLING_THREAD_COUNT)
+ @ConfigField(field = PropertyKeyConst.NAMING_POLLING_THREAD_COUNT)
private Integer pollingThreadCount =
Runtime.getRuntime().availableProcessors() / 2 + 1;
- @ConfigFiled(field = UtilAndComs.NACOS_NAMING_LOG_NAME)
+ @ConfigField(field = UtilAndComs.NACOS_NAMING_LOG_NAME)
private String logFileName;
- @ConfigFiled(field = UtilAndComs.NACOS_NAMING_LOG_LEVEL)
+ @ConfigField(field = UtilAndComs.NACOS_NAMING_LOG_LEVEL)
private String logLevel;
}
diff --git
a/eventmesh-registry/eventmesh-registry-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.registry.RegistryService
b/eventmesh-registry/eventmesh-registry-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.registry.RegistryService
new file mode 100644
index 000000000..3301d56e5
--- /dev/null
+++
b/eventmesh-registry/eventmesh-registry-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.registry.RegistryService
@@ -0,0 +1,16 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+nacos=org.apache.eventmesh.registry.nacos.NacosDiscoveryService
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
