diff --git a/conf/application.properties b/conf/application.properties
new file mode 100644
index 0000000..3987050
--- /dev/null
+++ b/conf/application.properties
@@ -0,0 +1,13 @@
+redkale.name=zhub-dev
+redkale.port=6560
+redkale.server[0].protocol=HTTP
+redkale.server[0].host=127.0.0.1
+redkale.server[0].port=80
+# redkale.server[0].root = root
+redkale.server[0].rest.autoload=true
+redkale.server[0].rest.path=
+redkale.server[0].services[0].autoload=true
+# zhub
+redkale.cluster.zhub[hub].addr=47.111.150.118:6066
+redkale.cluster.zhub[hub].auth=zchd@123456
+redkale.cluster.zhub[hub].groupid=venue-zhub
\ No newline at end of file
diff --git a/conf/application.xml b/conf/application.xml
deleted file mode 100644
index 3c2e3ed..0000000
--- a/conf/application.xml
+++ /dev/null
@@ -1,26 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/conf/kafak.properties b/conf/kafak.properties
deleted file mode 100644
index 37bcd72..0000000
--- a/conf/kafak.properties
+++ /dev/null
@@ -1,19 +0,0 @@
-# Producer
-#bootstrap.servers=47.111.150.118:6062
-#bootstrap.servers=121.196.17.55:6062
-bootstrap.servers=39.108.56.246:9092
-#bootstrap.servers=122.112.180.156:6062
-acks=all
-retries=0
-batch.size=16384
-linger.ms=1
-buffer.memory=33554432
-key.serializer=org.apache.kafka.common.serialization.StringSerializer
-value.serializer=org.apache.kafka.common.serialization.StringSerializer
-
-# Consumer
-enable.auto.commit=true
-auto.commit.interval.ms=1000
-group.id=
-key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
-value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
\ No newline at end of file
diff --git a/conf/logging.properties b/conf/logging.properties
new file mode 100644
index 0000000..ab86219
--- /dev/null
+++ b/conf/logging.properties
@@ -0,0 +1,18 @@
+handlers=java.util.logging.ConsoleHandler
+# handlers = java.util.logging.FileHandler
+############################################################
+.level=FINEST
+java.level=INFO
+javax.level=INFO
+com.sun.level=INFO
+sun.level=INFO
+jdk.level=INFO
+java.util.logging.FileHandler.level=FINER
+#10M
+java.util.logging.FileHandler.limit=10M
+java.util.logging.FileHandler.count=20
+java.util.logging.FileHandler.encoding=UTF-8
+java.util.logging.FileHandler.pattern=${APP_HOME}/logs-%tY%tm/log-%tY%tm%td.log
+java.util.logging.FileHandler.unusual=${APP_HOME}/logs-%tY%tm/log-warnerr-%tY%tm%td.log
+java.util.logging.FileHandler.append=true
+java.util.logging.ConsoleHandler.level=FINEST
diff --git a/conf/source.properties b/conf/source.properties
new file mode 100644
index 0000000..741210c
--- /dev/null
+++ b/conf/source.properties
@@ -0,0 +1,5 @@
+############ ClusterSource @Resource(name="hub") ############
+# redkale.cluster.zhub[hub].addr = 47.111.150.118:6066
+# redkale.cluster.zhub[hub].auth = zchd@123456
+# redkale.cluster.zhub[hub].groupid = venue-zhub
+
diff --git a/src/com/zdemo/AbstractConsumer.java b/src/com/zdemo/AbstractConsumer.java
index db3e02b..b3a48a2 100644
--- a/src/com/zdemo/AbstractConsumer.java
+++ b/src/com/zdemo/AbstractConsumer.java
@@ -1,6 +1,7 @@
package com.zdemo;
import org.redkale.convert.json.JsonConvert;
+import org.redkale.util.Resourcable;
import org.redkale.util.TypeToken;
import javax.annotation.Resource;
@@ -13,7 +14,7 @@ import java.util.function.Consumer;
* @author Liang
* @data 2020-09-05 23:18
*/
-public abstract class AbstractConsumer implements IConsumer {
+public abstract class AbstractConsumer extends ZhubAgentProvider implements IConsumer, Resourcable {
protected JsonConvert convert = JsonConvert.root();
@@ -24,10 +25,6 @@ public abstract class AbstractConsumer implements IConsumer {
protected abstract String getGroupid();
- protected boolean preInit() {
- return true;
- }
-
protected final Set getTopics() {
if (!eventMap.isEmpty()) {
return eventMap.keySet();
@@ -76,4 +73,10 @@ public abstract class AbstractConsumer implements IConsumer {
}
}
+ // --------------
+
+ @Override
+ public String resourceName() {
+ return super.getName();
+ }
}
diff --git a/src/com/zdemo/ZhubAgentProvider.java b/src/com/zdemo/ZhubAgentProvider.java
new file mode 100644
index 0000000..c122d4b
--- /dev/null
+++ b/src/com/zdemo/ZhubAgentProvider.java
@@ -0,0 +1,69 @@
+package com.zdemo;
+
+import org.redkale.boot.Application;
+import org.redkale.boot.NodeServer;
+import org.redkale.cluster.CacheClusterAgent;
+import org.redkale.cluster.ClusterAgent;
+import org.redkale.service.Service;
+import org.redkale.util.ResourceEvent;
+
+import java.net.InetSocketAddress;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.CompletableFuture;
+
+public abstract class ZhubAgentProvider extends ClusterAgent {
+
+ @Override
+ public void onResourceChange(ResourceEvent[] events) {
+
+ }
+
+ @Override
+ public void register(Application application) {
+
+ }
+
+ @Override
+ public void deregister(Application application) {
+
+ }
+
+ @Override
+ public CompletableFuture