|
@@ -81,7 +81,7 @@ public class TimeSeriesMessageWriterConnector {
|
|
|
* @param message 设备消息
|
|
* @param message 设备消息
|
|
|
* @return void
|
|
* @return void
|
|
|
*/
|
|
*/
|
|
|
- @Subscribe(topics = "/device/**/*/time-sync", id = "device-time-sync")
|
|
|
|
|
|
|
+ @Subscribe(topics = "/device/**/**/time-sync", id = "device-time-sync")
|
|
|
public Mono<Void> timeSync(DeviceMessage message) {
|
|
public Mono<Void> timeSync(DeviceMessage message) {
|
|
|
return registry.getDevice(message.getDeviceId())
|
|
return registry.getDevice(message.getDeviceId())
|
|
|
.map(DeviceOperator::messageSender)
|
|
.map(DeviceOperator::messageSender)
|