|
|
@@ -238,7 +238,7 @@ public class AliBridgeServer extends AbstractClusterUniqueTask<AliBridgeServer>
|
|
|
)
|
|
|
.flatMap(channel->
|
|
|
bridgeDeviceService
|
|
|
- .createUpdate().set(AliIotBridgeDeviceConfig::getState, BridgeDeviceStatus.success)
|
|
|
+ .createUpdate()
|
|
|
.set(AliIotBridgeDeviceConfig::getState,BridgeDeviceStatus.success)
|
|
|
.where(AliIotBridgeDeviceConfig::getOriginalIdentity,originalIdentity)
|
|
|
.execute()
|