From 4b3849b66ef6d114673ac338f7d7c7a1ab10b8d0 Mon Sep 17 00:00:00 2001
From: lxy <237809796@qq.com>
Date: Sat, 19 Sep 2020 13:49:50 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=EF=BC=9A=E6=B6=88=E8=B4=B9?=
 =?UTF-8?q?=E5=AF=B9=E8=B1=A1=E5=88=9D=E5=A7=8B=E5=8C=96=E6=98=AF=E5=90=A6?=
 =?UTF-8?q?=20=E5=BC=80=E5=90=AF=E4=BA=8B=E4=BB=B6=E7=9B=91=E5=90=AC?=
 =?UTF-8?q?=E6=8E=A7=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/com/zdemo/AbstractConsumer.java    | 3 ++-
 src/com/zdemo/IConsumer.java           | 2 +-
 src/com/zdemo/kafak/KafakConsumer.java | 4 +++-
 test/com/zdemo/test/MyConsumer.java    | 4 +++-
 4 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/src/com/zdemo/AbstractConsumer.java b/src/com/zdemo/AbstractConsumer.java
index 2793e44..ac6aeb0 100644
--- a/src/com/zdemo/AbstractConsumer.java
+++ b/src/com/zdemo/AbstractConsumer.java
@@ -14,7 +14,8 @@ public abstract class AbstractConsumer implements IConsumer {
 
     public final Map<String, EventType> eventMap = new HashMap<>();
 
-    public void preInit() {
+    public boolean preInit() {
+        return true;
     }
 
     public void addEventType(EventType... eventType) {
diff --git a/src/com/zdemo/IConsumer.java b/src/com/zdemo/IConsumer.java
index 32cdd25..48051be 100644
--- a/src/com/zdemo/IConsumer.java
+++ b/src/com/zdemo/IConsumer.java
@@ -6,7 +6,7 @@ import java.util.Collection;
 import java.util.logging.Logger;
 
 public interface IConsumer<T extends Event> {
-    TypeToken TYPE_TOKEN_STRING = new TypeToken<String>() {
+    TypeToken<String> TYPE_TOKEN_STRING = new TypeToken<String>() {
     };
     TypeToken<Integer> TYPE_TOKEN_INT = new TypeToken<Integer>() {
     };
diff --git a/src/com/zdemo/kafak/KafakConsumer.java b/src/com/zdemo/kafak/KafakConsumer.java
index ea08e2d..3b655c2 100644
--- a/src/com/zdemo/kafak/KafakConsumer.java
+++ b/src/com/zdemo/kafak/KafakConsumer.java
@@ -54,7 +54,9 @@ public abstract class KafakConsumer extends AbstractConsumer implements IConsume
 
     @Override
     public final void init(AnyValue config) {
-        preInit();
+        if (!preInit()) {
+            return;
+        }
         try (FileInputStream fis = new FileInputStream(new File(APP_HOME, "conf/kafak.properties"));) {
             props = new Properties();
             props.load(fis);
diff --git a/test/com/zdemo/test/MyConsumer.java b/test/com/zdemo/test/MyConsumer.java
index 223b400..2daf5b1 100644
--- a/test/com/zdemo/test/MyConsumer.java
+++ b/test/com/zdemo/test/MyConsumer.java
@@ -12,7 +12,7 @@ public class MyConsumer extends KafakConsumer {
     }
 
     @Override
-    public void preInit() {
+    public boolean preInit() {
         addEventType(
                 EventType.of("a1", new TypeToken<Float>() {
                 }, r -> {
@@ -23,5 +23,7 @@ public class MyConsumer extends KafakConsumer {
                     System.out.println("我收到了消息 主题bx 事件：" + str);
                 })
         );
+
+        return true;
     }
 }