|
|
@@ -94,7 +94,7 @@ public class DeviceDirectiveController implements
|
|
|
return Flux.fromStream(t2.stream())
|
|
|
.flatMap(operator -> Mono.just(operator.messageSender()))
|
|
|
.flatMap(sender->{
|
|
|
- message.addHeader(Headers.async,true);
|
|
|
+// message.addHeader(Headers.async,true);
|
|
|
return sender.send(message)
|
|
|
.onErrorContinue((e,obj)->log.warn("指令下发失败{}",message))
|
|
|
.then();
|