|
|
|
@ -22,7 +22,6 @@ import io.grpc.Server; |
|
|
|
import io.grpc.netty.shaded.io.grpc.netty.NettyServerBuilder; |
|
|
|
import io.grpc.stub.StreamObserver; |
|
|
|
import jakarta.annotation.Nullable; |
|
|
|
import jakarta.annotation.PostConstruct; |
|
|
|
import jakarta.annotation.PreDestroy; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
@ -63,6 +62,7 @@ import org.thingsboard.server.queue.discovery.TopicService; |
|
|
|
import org.thingsboard.server.queue.kafka.TbKafkaSettings; |
|
|
|
import org.thingsboard.server.queue.kafka.TbKafkaTopicConfigs; |
|
|
|
import org.thingsboard.server.queue.provider.TbCoreQueueFactory; |
|
|
|
import org.thingsboard.server.queue.util.AfterStartUp; |
|
|
|
import org.thingsboard.server.queue.util.TbCoreComponent; |
|
|
|
import org.thingsboard.server.service.edge.EdgeContextComponent; |
|
|
|
import org.thingsboard.server.service.telemetry.TelemetrySubscriptionService; |
|
|
|
@ -162,8 +162,8 @@ public class EdgeGrpcService extends EdgeRpcServiceGrpc.EdgeRpcServiceImplBase i |
|
|
|
|
|
|
|
private ScheduledExecutorService executorService; |
|
|
|
|
|
|
|
@PostConstruct |
|
|
|
public void init() { |
|
|
|
@AfterStartUp(order = AfterStartUp.REGULAR_SERVICE) |
|
|
|
public void onStartUp() { |
|
|
|
log.info("Initializing Edge RPC service!"); |
|
|
|
NettyServerBuilder builder = NettyServerBuilder.forPort(rpcPort) |
|
|
|
.permitKeepAliveTime(clientMaxKeepAliveTimeSec, TimeUnit.SECONDS) |
|
|
|
|