Browse Source

Tell edge events with normal priority. Updated sync request timeout to 20 seconds

pull/7093/head
Volodymyr Babak 4 years ago
parent
commit
2ed85cb294
  1. 2
      application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcService.java
  2. 2
      application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java

2
application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcService.java

@ -296,7 +296,7 @@ public class EdgeGrpcService extends EdgeRpcServiceGrpc.EdgeRpcServiceImplBase i
log.trace("[{}] timeout for processing sync edge request.", requestId); log.trace("[{}] timeout for processing sync edge request.", requestId);
consumer.accept(new FromEdgeSyncResponse(requestId, request.getTenantId(), request.getEdgeId(), false)); consumer.accept(new FromEdgeSyncResponse(requestId, request.getTenantId(), request.getEdgeId(), false));
} }
}, 10, TimeUnit.SECONDS); }, 20, TimeUnit.SECONDS);
} }
private void processSyncResponse(FromEdgeSyncResponse response) { private void processSyncResponse(FromEdgeSyncResponse response) {

2
application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java

@ -551,7 +551,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
private void forwardToAppActor(UUID id, Optional<TbActorMsg> actorMsg, TbCallback callback) { private void forwardToAppActor(UUID id, Optional<TbActorMsg> actorMsg, TbCallback callback) {
if (actorMsg.isPresent()) { if (actorMsg.isPresent()) {
log.trace("[{}] Forwarding message to App Actor {}", id, actorMsg.get()); log.trace("[{}] Forwarding message to App Actor {}", id, actorMsg.get());
actorContext.tellWithHighPriority(actorMsg.get()); actorContext.tell(actorMsg.get());
} }
callback.onSuccess(); callback.onSuccess();
} }

Loading…
Cancel
Save