|
|
@@ -71,7 +71,7 @@ public class DeviceDirectiveController implements
|
|
|
.flatMap(operator -> Mono.just(operator.messageSender()))
|
|
|
.flatMap(sender->{
|
|
|
directive.getDownstream().addHeader(Headers.async,true);
|
|
|
- directive.getDownstream().setMessageId(IdUtils.newUUID());
|
|
|
+ ( (CommonDeviceMessage)directive.getDownstream()).setMessageId(IdUtils.newUUID());
|
|
|
return sender.send(directive.getDownstream())
|
|
|
.onErrorContinue((e,obj)->log.warn("指令重新发送失败{}",directive))
|
|
|
.then();
|