From c4639fcabf4771ff8f9cf486156ab78a5eb2c190 Mon Sep 17 00:00:00 2001
From: lxy <237809796@qq.com>
Date: Wed, 3 Feb 2021 16:45:42 +0800
Subject: [PATCH] .

---
 src/com/zdemo/AbstractConsumer.java    | 6 +++---
 src/com/zdemo/kafak/KafakConsumer.java | 2 --
 src/com/zdemo/zhub/ZHubClient.java     | 2 +-
 test/com/zdemo/test/MyConsumer.java    | 2 +-
 4 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/src/com/zdemo/AbstractConsumer.java b/src/com/zdemo/AbstractConsumer.java
index ae39551..9a3577a 100644
--- a/src/com/zdemo/AbstractConsumer.java
+++ b/src/com/zdemo/AbstractConsumer.java
@@ -64,10 +64,10 @@ public abstract class AbstractConsumer implements IConsumer {
             for (String x : topic.split(",")) {
                 subscribe(x, typeToken, consumer);
             }
+        } else {
+            eventMap.put(topic, EventType.of(topic, typeToken, consumer));
+            subscribe(topic);
         }
-
-        eventMap.put(topic, EventType.of(topic, typeToken, consumer));
-        subscribe(topic);
     }
 
 }
diff --git a/src/com/zdemo/kafak/KafakConsumer.java b/src/com/zdemo/kafak/KafakConsumer.java
index ef1dac5..739538c 100644
--- a/src/com/zdemo/kafak/KafakConsumer.java
+++ b/src/com/zdemo/kafak/KafakConsumer.java
@@ -30,8 +30,6 @@ public abstract class KafakConsumer extends AbstractConsumer implements IConsume
     @Resource(name = "APP_HOME")
     protected File APP_HOME;
 
-    public abstract String getGroupid();
-
     private final LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();
 
     @Override
diff --git a/src/com/zdemo/zhub/ZHubClient.java b/src/com/zdemo/zhub/ZHubClient.java
index 483c277..2e7c38b 100644
--- a/src/com/zdemo/zhub/ZHubClient.java
+++ b/src/com/zdemo/zhub/ZHubClient.java
@@ -25,7 +25,7 @@ import java.util.logging.Logger;
 
 public abstract class ZHubClient extends AbstractConsumer implements IConsumer, IProducer, Service {
 
-    Logger logger = Logger.getLogger(ZHubClient.class.getSimpleName());
+    public Logger logger = Logger.getLogger(ZHubClient.class.getSimpleName());
 
     @Resource(name = "property.zhub.host")
     private String host = "127.0.0.1";
diff --git a/test/com/zdemo/test/MyConsumer.java b/test/com/zdemo/test/MyConsumer.java
index 5e8cf6a..0bfef54 100644
--- a/test/com/zdemo/test/MyConsumer.java
+++ b/test/com/zdemo/test/MyConsumer.java
@@ -9,7 +9,7 @@ public class MyConsumer extends ZHubClient {
     }
 
     @Override
-    public boolean preInit() {
+    protected boolean preInit() {
         return true;
     }
 }