|
|
|
@ -480,7 +480,7 @@ public class DefaultLwM2mUplinkMsgHandler extends LwM2MExecutorAwareService impl |
|
|
|
CountDownLatch latch = new CountDownLatch(targetIds.size()); |
|
|
|
targetIds.forEach(versionedId -> sendReadRequest(lwM2MClient, versionedId, |
|
|
|
new TbLwM2MLatchCallback<>(latch, new TbLwM2MReadCallback(this, logService, lwM2MClient, versionedId)))); |
|
|
|
latch.await(); |
|
|
|
latch.await(config.getTimeout(), TimeUnit.MILLISECONDS); |
|
|
|
} catch (InterruptedException e) { |
|
|
|
log.error("[{}] Failed to await Read requests!", lwM2MClient.getEndpoint(), e); |
|
|
|
} catch (Exception e) { |
|
|
|
@ -498,7 +498,7 @@ public class DefaultLwM2mUplinkMsgHandler extends LwM2MExecutorAwareService impl |
|
|
|
targetIds.forEach(targetId -> sendObserveRequest(lwM2MClient, targetId, |
|
|
|
new TbLwM2MLatchCallback<>(latch, new TbLwM2MObserveCallback(this, logService, lwM2MClient, targetId)))); |
|
|
|
|
|
|
|
latch.await(); |
|
|
|
latch.await(config.getTimeout(), TimeUnit.MILLISECONDS); |
|
|
|
} catch (InterruptedException e) { |
|
|
|
log.error("[{}] Failed to await Observe requests!", lwM2MClient.getEndpoint(), e); |
|
|
|
} catch (Exception e) { |
|
|
|
|