|
|
@@ -73,6 +73,7 @@ public class DeviceDirectiveSendInterceptor implements DeviceMessageSenderInterc
|
|
|
// .where(DeviceDirectivesEntity::getDeviceId,message.getDeviceId())
|
|
|
.where(DeviceDirectivesEntity::getMessageId,message.getMessageId())
|
|
|
.set(DeviceDirectivesEntity::getLastError,e.getMessage())
|
|
|
+ .set(DeviceDirectivesEntity::getDownstream,message)
|
|
|
.set(DeviceDirectivesEntity::getState,DirectiveState.sendError)
|
|
|
.execute())
|
|
|
.thenMany(reply);
|