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

修改：topic 消息接收日志打印级别

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

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

@ -211,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); logger.log(Level.FINE, "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();
@ -266,7 +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 + "]"); // 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) {