fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Rename some variable

Browse Source
This commit is contained in:
hongqiaowei
2021-10-14 11:13:10 +08:00
parent fbd54ab95c
commit a58646cc22
1 changed files with 23 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
fizz-core/src/main/java/we/global_resource/GlobalResourceService.java
View File

@@ -90,29 +90,29 @@ public class GlobalResourceService {
} }
private Mono<Result<?>> initGlobalResource() { private Mono<Result<?>> initGlobalResource() {
Flux<Map.Entry<Object, Object>> dicts = rt.opsForHash().entries("fizz_global_resource"); Flux<Map.Entry<Object, Object>> resources = rt.opsForHash().entries("fizz_global_resource");
dicts.collectList() resources.collectList()
.defaultIfEmpty(Collections.emptyList()) .defaultIfEmpty(Collections.emptyList())
.flatMap( .flatMap(
es -> { es -> {
if (Fizz.context != null) { if (Fizz.context != null) {
for (Map.Entry<Object, Object> e : es) { for (Map.Entry<Object, Object> e : es) {
String json = (String) e.getValue(); String json = (String) e.getValue();
GlobalResource r = JacksonUtils.readValue(json, GlobalResource.class); GlobalResource r = JacksonUtils.readValue(json, GlobalResource.class);
resourceMap.put(r.key, r); resourceMap.put(r.key, r);
objectMap.put(r.key, r.originalVal); objectMap.put(r.key, r.originalVal);
log.info("init global resource {}", r.key); log.info("init global resource {}", r.key);
}
} }
return Mono.empty();
} }
return Mono.empty(); )
} .doOnError(
) t -> {
.doOnError( log.error("init global resource", t);
t -> { }
log.error("init global resource", t); )
} .block();
)
.block();
return Mono.just(Result.succ()); return Mono.just(Result.succ());
} }
@@ -143,8 +143,8 @@ public class GlobalResourceService {
objectMap.remove(r.key); objectMap.remove(r.key);
log.info("remove global resource {}", r.key); log.info("remove global resource {}", r.key);
} else { } else {
GlobalResource put = resourceMap.put(r.key, r); resourceMap.put(r.key, r);
objectMap.put(r.key, r.originalVal); objectMap.put(r.key, r.originalVal);
log.info("update global resource {}", r.key); log.info("update global resource {}", r.key);
} }
updateResNode(); updateResNode();