From 1171304a049e8ee16983e3f169b9e2616bc0ba1d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=A2=81=E6=98=BE=E4=BC=98?= <237809796@qq.com>
Date: Thu, 23 Jun 2022 19:41:21 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=EF=BC=9Azhub=20=E9=AA=8C?=
=?UTF-8?q?=E6=9D=83=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
conf/application.xml | 2 +-
src/com/zdemo/zhub/ZHubClient.java | 7 ++++++-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/conf/application.xml b/conf/application.xml
index c519a89..3c2e3ed 100644
--- a/conf/application.xml
+++ b/conf/application.xml
@@ -4,7 +4,7 @@
-
+
diff --git a/src/com/zdemo/zhub/ZHubClient.java b/src/com/zdemo/zhub/ZHubClient.java
index ec4cbe0..5ea5eb5 100644
--- a/src/com/zdemo/zhub/ZHubClient.java
+++ b/src/com/zdemo/zhub/ZHubClient.java
@@ -33,7 +33,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
public Logger logger = Logger.getLogger(ZHubClient.class.getSimpleName());
private String addr = "127.0.0.1:1216";
- //private String password = "";
+ private String auth = "";
private String groupid = "";
//private ReentrantLock lock = new ReentrantLock();
@@ -73,6 +73,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
addr = addr + ":" + port;
}
+ auth = config.getOrDefault("auth", auth);
groupid = config.getValue("groupid", groupid);
}
@@ -169,7 +170,10 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
String topic = reader.readLine(); // name
timerQueue.add(timerMap.get(topic));
+ continue;
}
+
+ logger.finest(readLine);
} catch (IOException e) {
if (e instanceof SocketException) {
initSocket(Integer.MAX_VALUE);
@@ -344,6 +348,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
if (groupid == null || groupid.isEmpty()) {
throw new RuntimeException("ZHubClient groupid can not is empty");
}
+ send("auth", auth);
send("groupid " + groupid);
StringBuffer buf = new StringBuffer("subscribe lock");