diff --git a/pom.xml b/pom.xml index 1e143be..f35dfc2 100644 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.3 + 3.2.12 com.orange.lo.sample.lo2iot @@ -41,7 +41,7 @@ com.microsoft.azure.sdk.iot iot-service-client - 2.1.7 + 2.1.9 org.springframework.boot @@ -51,7 +51,7 @@ com.microsoft.azure.sdk.iot iot-device-client - 2.4.1 + 2.5.0 com.microsoft.azure diff --git a/src/main/java/com/orange/lo/sample/lo2iothub/azure/MultiplexingClientManager.java b/src/main/java/com/orange/lo/sample/lo2iothub/azure/MultiplexingClientManager.java index b22d4c5..0b29bcd 100644 --- a/src/main/java/com/orange/lo/sample/lo2iothub/azure/MultiplexingClientManager.java +++ b/src/main/java/com/orange/lo/sample/lo2iothub/azure/MultiplexingClientManager.java @@ -145,7 +145,8 @@ private void registerDeviceClientsAsMultiplexed() { if (!deviceClientManagersToRegister.isEmpty()) { List deviceClientList = deviceClientManagersToRegister.stream().map(dcm -> dcm.getDeviceClient()).collect(Collectors.toList()); try { - this.multiplexingClient.registerDeviceClients(deviceClientList); + LOG.info("Starts device clients registration {} for multiplexing client: {}", deviceClientManagersToRegister.stream().map(dcm -> dcm.getDeviceClient().getConfig().getDeviceId()).collect(Collectors.toSet()), multiplexingClientId); + this.multiplexingClient.registerDeviceClients(deviceClientList, 25000L); this.multiplexedDeviceClientManagers.putAll(deviceClientManagersToRegister.stream().collect(Collectors.toMap(dcm -> dcm.getDeviceClient().getConfig().getDeviceId() , dcm -> dcm))); LOG.info("Registered device clients {} for multiplexing client: {}", deviceClientManagersToRegister.stream().map(dcm -> dcm.getDeviceClient().getConfig().getDeviceId()).collect(Collectors.toSet()), multiplexingClientId); deviceClientManagersToRegister.clear(); diff --git a/src/main/java/com/orange/lo/sample/lo2iothub/lo/LoCommandSender.java b/src/main/java/com/orange/lo/sample/lo2iothub/lo/LoCommandSender.java index f80115b..316d3ec 100644 --- a/src/main/java/com/orange/lo/sample/lo2iothub/lo/LoCommandSender.java +++ b/src/main/java/com/orange/lo/sample/lo2iothub/lo/LoCommandSender.java @@ -10,9 +10,6 @@ import com.fasterxml.jackson.databind.ObjectMapper; import com.microsoft.azure.sdk.iot.device.IotHubMessageResult; import com.orange.lo.sample.lo2iothub.exceptions.CommandException; -import com.orange.lo.sdk.LOApiClient; -import com.orange.lo.sdk.rest.devicemanagement.Commands; -import com.orange.lo.sdk.rest.devicemanagement.DeviceManagement; import com.orange.lo.sdk.rest.model.CommandAddRequest; import java.lang.invoke.MethodHandles;