mirror of
https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git
synced 2026-01-25 07:46:40 +08:00
feat(ProxyIp): implement proxy IP management service with API integration and scheduling
This commit is contained in:
@@ -127,7 +127,15 @@ public class MtjywpmDataListener {
|
||||
return;
|
||||
}
|
||||
|
||||
list.forEach(e -> sendIfMatch(e, sysId, jsonNode));
|
||||
list.forEach(
|
||||
e -> {
|
||||
try {
|
||||
|
||||
sendIfMatch(e, sysId, jsonNode);
|
||||
} catch (Exception exception) {
|
||||
log.error("notify subscriber error {} {}", e.getName(), sysId, exception);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
@SneakyThrows
|
||||
@@ -137,8 +145,10 @@ public class MtjywpmDataListener {
|
||||
|
||||
CommonQuery commonQuery = new CommonQuery();
|
||||
|
||||
commonQuery.setItems(new ArrayList<>(objectMapper.readValue(queryJson, new TypeReference<List<CommonQuery.QueryItem>>() {
|
||||
})));
|
||||
commonQuery.setItems(
|
||||
new ArrayList<>(
|
||||
objectMapper.readValue(
|
||||
queryJson, new TypeReference<List<CommonQuery.QueryItem>>() {})));
|
||||
commonQuery
|
||||
.getItems()
|
||||
.add(
|
||||
|
||||
Reference in New Issue
Block a user