in src/main/java/org/apache/rocketmq/dashboard/task/DashboardCollectTask.java [236:254]
private List<String> appendData(List<String> newTpsList, List<String> oldTpsList) {
List<String> result = Lists.newArrayList();
if (newTpsList == null || newTpsList.size() == 0) {
return oldTpsList;
}
if (oldTpsList == null || oldTpsList.size() == 0) {
return newTpsList;
}
String oldLastTps = oldTpsList.get(oldTpsList.size() - 1);
Long oldLastTimestamp = Long.parseLong(oldLastTps.split(",")[0]);
String newFirstTps = newTpsList.get(0);
Long newFirstTimestamp = Long.parseLong(newFirstTps.split(",")[0]);
if (oldLastTimestamp.longValue() < newFirstTimestamp.longValue()) {
result.addAll(oldTpsList);
result.addAll(newTpsList);
return result;
}
return newTpsList;
}