update: push callback req to manager

This commit is contained in:
hongqiaowei
2021-01-28 19:54:04 +08:00
parent f9e6931cf5
commit 4fe88769d6

View File

@@ -133,7 +133,7 @@ public class CallbackFilter extends FizzWebFilter {
private Mono<? extends Void> requestBackends(ServerWebExchange exchange, HttpHeaders headers, DataBuffer body, CallbackConfig cc, HashMap<String, ServiceInstance> service2instMap) {
ServerHttpRequest req = exchange.getRequest();
int rs = cc.receivers.size();
Mono<Object>[] monos = new Mono[rs]; // cant Mono[] ?
Mono<Object>[] monos = new Mono[rs];
for (int i = 0; i < rs; i++) {
Receiver r = cc.receivers.get(i);
Mono send;