lxy/zhub-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增：topic 接收日志, zhub 消息发送日志

Browse Source
This commit is contained in:
梁显优 2023-04-03 19:24:54 +08:00
parent aeba8fa635
commit 6f1d1fc98a
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/com/zdemo/zhub/ZHubClient.java
View File

@ -203,6 +203,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
} }
}, 1); }, 1);
// topic msg
threadBuilder.accept(() -> { threadBuilder.accept(() -> {
while (true) { while (true) {
Event<String> event = null; Event<String> event = null;
@ -210,7 +211,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
if ((event = topicQueue.take()) == null) { if ((event = topicQueue.take()) == null) {
continue; continue;
} }
logger.log(Level.INFO, "topic[" + event.topic + "] :" + event.value);
accept(event.topic, event.value); accept(event.topic, event.value);
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
@ -265,6 +266,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
if ((msg = sendMsgQueue.take()) == null) { if ((msg = sendMsgQueue.take()) == null) {
continue; continue;
} }
logger.log(Level.FINEST, "send-msg: [" + msg + "]");
writer.write(msg.getBytes()); writer.write(msg.getBytes());
writer.flush(); writer.flush();
} catch (InterruptedException e) { } catch (InterruptedException e) {