clean inactive request topic

pull/1490/merge^2
gongdewei 4 years ago
parent 33adfad1d0
commit c073b2c777

@ -215,9 +215,9 @@ public class MessageExchangeServiceImpl implements MessageExchangeService {
long now = System.currentTimeMillis();
List<TopicData> topicDataList = new ArrayList<>(topicMap.values());
for (TopicData topicData : topicDataList) {
if (topicData.topic instanceof ActionRequestTopic) {
continue;
}
// if (topicData.topic instanceof ActionRequestTopic) {
// continue;
// }
long idle = now - topicData.getLastActiveTime();
if (!topicData.isSubscribed() && idle > timeout) {
try {

@ -188,7 +188,7 @@ public class LegacyApiController {
long idleTime = currentTimeMillis - entry.getValue().time;
boolean outdated = idleTime > topicSurvivalTimeMills;
if (outdated) {
logger.info("Removing outdated request data, idle time: {}, sessionId: {}, request: {}", idleTime, entry.getKey(), entry.getValue());
logger.info("Removing inactive request data, idle time: {}, sessionId: {}, request: {}", idleTime, entry.getKey(), entry.getValue());
}
return outdated;
});

Loading…
Cancel
Save