Device client registration timeout less than MQTT timeout. Information just before entering to the Azure SDK device client registration method. New spring, iot-service-client and iot-device-client. Code Cleanup.

Author: grzegorzswistak

pom.xml

@@ -4,7 +4,7 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>3.2.3</version>
+		<version>3.2.12</version>
 		<relativePath /> <!-- lookup parent from repository -->
 	</parent>
 	<groupId>com.orange.lo.sample.lo2iot</groupId>
@@ -41,7 +41,7 @@
         <dependency>
             <groupId>com.microsoft.azure.sdk.iot</groupId>
             <artifactId>iot-service-client</artifactId>
-            <version>2.1.7</version>
+            <version>2.1.9</version>
         </dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
@@ -51,7 +51,7 @@
         <dependency>
             <groupId>com.microsoft.azure.sdk.iot</groupId>
             <artifactId>iot-device-client</artifactId>
-            <version>2.4.1</version>
+            <version>2.5.0</version>
         </dependency>
 		<dependency>
 		    <groupId>com.microsoft.azure</groupId>

src/main/java/com/orange/lo/sample/lo2iothub/azure/MultiplexingClientManager.java

@@ -145,7 +145,8 @@ private void registerDeviceClientsAsMultiplexed()  {
             if (!deviceClientManagersToRegister.isEmpty()) {
                 List<DeviceClient> 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();

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;