Undo renaming edge session and edge service

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

@@ -23,10 +23,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.ResourceUtils;
-import org.thingsboard.server.gen.edge.v1.EdgeRpcServiceGrpc;
 import org.thingsboard.server.gen.edge.v1.EdgeRpcServiceGrpc.EdgeRpcServiceImplBase;
 import org.thingsboard.server.queue.util.AfterStartUp;
-import org.thingsboard.server.service.edge.rpc.service.EdgeRpcServiceImpl;
 
 import java.io.IOException;
 import java.io.InputStream;

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

@@ -77,7 +77,7 @@ import static org.thingsboard.server.service.state.DefaultDeviceStateService.LAS
 @Service
 @Slf4j
 @RequiredArgsConstructor
-public class EdgeRpcServiceImpl extends EdgeRpcServiceGrpc.EdgeRpcServiceImplBase implements EdgeRpcService {
+public class EdgeGrpcService extends EdgeRpcServiceGrpc.EdgeRpcServiceImplBase implements EdgeRpcService {
 
     @Value("${edges.send_scheduler_pool_size}")
     private int sendSchedulerPoolSize;

application/src/main/java/org/thingsboard/server/service/edge/rpc/session/BaseEdgeSession.java → application/src/main/java/org/thingsboard/server/service/edge/rpc/session/EdgeGrpcSession.java

@@ -78,7 +78,7 @@ import java.util.function.BiConsumer;
 
 @Slf4j
 @RequiredArgsConstructor
-public class BaseEdgeSession implements EdgeSession {
+public class EdgeGrpcSession implements EdgeSession {
 
     private static final int MAX_DOWNLINK_ATTEMPTS = 3;
     private static final String RATE_LIMIT_REACHED = "Rate limit reached";

application/src/main/java/org/thingsboard/server/service/edge/rpc/session/manager/AbstractEdgeGrpcSessionManager.java

@@ -31,7 +31,7 @@ import org.thingsboard.server.service.edge.EdgeMsgConstructorUtils;
 import org.thingsboard.server.service.edge.rpc.DownlinkMessageMapper;
 import org.thingsboard.server.service.edge.rpc.EdgeSessionState;
 import org.thingsboard.server.service.edge.rpc.EdgeUplinkMessageDispatcher;
-import org.thingsboard.server.service.edge.rpc.session.BaseEdgeSession;
+import org.thingsboard.server.service.edge.rpc.session.EdgeGrpcSession;
 import org.thingsboard.server.service.edge.rpc.session.EdgeGrpcSessionDelegate;
 import org.thingsboard.server.service.edge.rpc.session.EdgeSession;
 import org.thingsboard.server.service.edge.rpc.session.ZombieSessionCleanupService;
@@ -79,7 +79,7 @@ public abstract class AbstractEdgeGrpcSessionManager extends EdgeGrpcSessionDele
         }
         initLock.lock();
         try {
-            this.session = new BaseEdgeSession(
+            this.session = new EdgeGrpcSession(
                     this, ctx, outputStream, downlinkMessageMapper, uplinkMessageDispatcher,
                     sessionOpenListener, sessionCloseListener,
                     sendDownlinkExecutorService, maxInboundMessageSize, maxHighPriorityQueueSizePerSession);