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

修改：日志输出

Browse Source
This commit is contained in:
梁显优 2023-04-12 21:09:32 +08:00
parent 6c49e7c3f6
commit a8788b419d
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -128,6 +128,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
value += s; // value
} while (clen > 0 && clen > strLength(value));
logger.finest("topic[" + topic + "]: " + value);
// lock msg
if ("lock".equals(topic)) {
@ -166,6 +167,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
reader.readLine(); //$n len(key)
String topic = reader.readLine(); // name
logger.finest("timer[" + topic + "]: ");
timerQueue.add(timerMap.get(topic));
continue;
}
@ -208,7 +210,6 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
if ((event = topicQueue.take()) == null) {
continue;
}
logger.log(Level.FINE, "topic[" + event.topic + "] :" + event.value);
accept(event.topic, event.value);
} catch (InterruptedException e) {
e.printStackTrace();
@ -216,7 +217,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
logger.log(Level.WARNING, "topic[" + event.topic + "] event accept error :" + event.value, e);
}
}
}, 1);
}, 16);
// rpc back
threadBuilder.accept(() -> {