修改：timer api

src/com/zdemo/zdb/ZHubConsumer.java

@@ -146,7 +146,7 @@ public abstract class ZHubConsumer extends AbstractConsumer implements IConsumer
 
             // 重连 timer 订阅
             timerMap.forEach((name, timer) -> {
-                send("timer", name, timer.expr, timer.single ? "a" : "x");
+                send("timer", name);
             });
         } catch (IOException e) {
             logger.log(Level.WARNING, "Zdb Consumer 初始化失败！", e);
@@ -180,43 +180,33 @@ public abstract class ZHubConsumer extends AbstractConsumer implements IConsumer
     // timer
     private ConcurrentHashMap<String, Timer> timerMap = new ConcurrentHashMap();
 
-    public void timer(String name, String expr, Runnable run) {
+    public void timer(String name, Runnable run) {
-        timerMap.put(name, new Timer(name, expr, run, false));
+        timerMap.put(name, new Timer(name, run));
-        send("timer", name, expr, "x");
+        send("timer", name);
     }
 
-    public void timerSingle(String name, String expr, Runnable run) {
+    public void reloadTimer() {
-        send("timer", name, expr, "a");
+        send("cmd", "reload-timer-config");
-        timerMap.put(name, new Timer(name, expr, run, true));
     }
 
     class Timer {
         String name;
-        String expr;
+        //String expr;
         Runnable runnable;
-        boolean single;
+        //boolean single;
 
         public String getName() {
             return name;
         }
 
-        public String getExpr() {
-            return expr;
-        }
 
         public Runnable getRunnable() {
             return runnable;
         }
 
-        public boolean isSingle() {
+        public Timer(String name, Runnable runnable) {
-            return single;
-        }
-
-        public Timer(String name, String expr, Runnable runnable, boolean single) {
             this.name = name;
-            this.expr = expr;
             this.runnable = runnable;
-            this.single = single;
         }
     }
 }

test/com/zdemo/test/AppTest.java

@@ -37,7 +37,7 @@ public class AppTest {
                     })
             );*/
 
-            consumer.timerSingle("a", "*/10 * * * * *", () -> {
+            consumer.timer("a", () -> {
                 System.out.println(Utility.now() + " timer a 执行了");
             });