|
|
@ -382,7 +382,7 @@ public class DefaultTransportApiService implements TransportApiService { |
|
|
|| !gatewayId.toString().equals(deviceAdditionalInfo.get(DataConstants.LAST_CONNECTED_GATEWAY).asText()))) { |
|
|
|| !gatewayId.toString().equals(deviceAdditionalInfo.get(DataConstants.LAST_CONNECTED_GATEWAY).asText()))) { |
|
|
ObjectNode newDeviceAdditionalInfo = (ObjectNode) deviceAdditionalInfo; |
|
|
ObjectNode newDeviceAdditionalInfo = (ObjectNode) deviceAdditionalInfo; |
|
|
newDeviceAdditionalInfo.put(DataConstants.LAST_CONNECTED_GATEWAY, gatewayId.toString()); |
|
|
newDeviceAdditionalInfo.put(DataConstants.LAST_CONNECTED_GATEWAY, gatewayId.toString()); |
|
|
Device savedDevice = deviceService.saveDevice(device); |
|
|
deviceService.saveDevice(device); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
GetOrCreateDeviceFromGatewayResponseMsg.Builder builder = GetOrCreateDeviceFromGatewayResponseMsg.newBuilder() |
|
|
GetOrCreateDeviceFromGatewayResponseMsg.Builder builder = GetOrCreateDeviceFromGatewayResponseMsg.newBuilder() |
|
|
@ -412,7 +412,7 @@ public class DefaultTransportApiService implements TransportApiService { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private ListenableFuture<TransportApiResponseMsg> handle(ProvisionDeviceRequestMsg requestMsg) { |
|
|
private ListenableFuture<TransportApiResponseMsg> handle(ProvisionDeviceRequestMsg requestMsg) { |
|
|
ListenableFuture<ProvisionResponse> provisionResponseFuture = null; |
|
|
ListenableFuture<ProvisionResponse> provisionResponseFuture; |
|
|
try { |
|
|
try { |
|
|
provisionResponseFuture = Futures.immediateFuture(deviceProvisionService.provisionDevice( |
|
|
provisionResponseFuture = Futures.immediateFuture(deviceProvisionService.provisionDevice( |
|
|
new ProvisionRequest( |
|
|
new ProvisionRequest( |
|
|
|