[#11497] Cleanup

pinpoint-apm · Oct 2, 2024 · 3632939 · 3632939
1 parent 010d104
commit 3632939
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 14 deletions.
diff --git a/...rp/pinpoint/realtime/collector/receiver/grpc/ActiveThreadCountResponseStreamObserver.java b/...rp/pinpoint/realtime/collector/receiver/grpc/ActiveThreadCountResponseStreamObserver.java
@@ -31,7 +31,7 @@
 /**
  * @author youngjin.kim2
  */
-public abstract class ActiveThreadCountResponseStreamObserver implements StreamObserver<PCmdActiveThreadCountRes> {
+public class ActiveThreadCountResponseStreamObserver implements StreamObserver<PCmdActiveThreadCountRes> {
 
     private static final Logger logger = LogManager.getLogger(ActiveThreadCountResponseStreamObserver.class);
 
@@ -116,8 +116,12 @@ public void onCompleted() {
         }
     }
 
-    protected abstract long extractSinkId(PCmdActiveThreadCountRes response);
+    private long extractSinkId(PCmdActiveThreadCountRes response) {
+        return response.getCommonStreamResponse().getResponseId();
+    }
 
-    protected abstract int extractSequence(PCmdActiveThreadCountRes response);
+    private int extractSequence(PCmdActiveThreadCountRes response) {
+        return response.getCommonStreamResponse().getSequenceId();
+    }
 
 }
diff --git a/...main/java/com/navercorp/pinpoint/realtime/collector/receiver/grpc/GrpcCommandService.java b/...main/java/com/navercorp/pinpoint/realtime/collector/receiver/grpc/GrpcCommandService.java
@@ -287,17 +287,7 @@ public void commandActiveThreadLightDump(PCmdActiveThreadLightDumpRes response,
     @Override
     public StreamObserver<PCmdActiveThreadCountRes> commandStreamActiveThreadCount(StreamObserver<Empty> responseObserver) {
         ServerCallStreamObserver<Empty> serverResponseObserver = (ServerCallStreamObserver<Empty>) responseObserver;
-        return new ActiveThreadCountResponseStreamObserver(serverResponseObserver, this.activeThreadCountSinkRepo) {
-            @Override
-            protected long extractSinkId(PCmdActiveThreadCountRes response) {
-                return response.getCommonStreamResponse().getResponseId();
-            }
-
-            @Override
-            protected int extractSequence(PCmdActiveThreadCountRes response) {
-                return response.getCommonStreamResponse().getSequenceId();
-            }
-        };
+        return new ActiveThreadCountResponseStreamObserver(serverResponseObserver, this.activeThreadCountSinkRepo);
     }
 
     private <T> void emitMono(T response, StreamObserver<Empty> responseObserver, Publisher<T> sink) {