[pinpoint-apm#9932] Removed thrift dependency of Agent module

Author: emeroad

collector/src/main/java/com/navercorp/pinpoint/collector/cluster/ClusterPointRepository.java

@@ -16,7 +16,6 @@
 
 package com.navercorp.pinpoint.collector.cluster;
 
-import com.navercorp.pinpoint.collector.cluster.grpc.GrpcAgentConnection;
 import com.navercorp.pinpoint.collector.receiver.grpc.PinpointGrpcServer;
 import com.navercorp.pinpoint.common.server.cluster.ClusterKey;
 import com.navercorp.pinpoint.rpc.common.SocketStateCode;

collector/src/main/java/com/navercorp/pinpoint/collector/cluster/grpc/GrpcAgentConnection.java renamed to collector/src/main/java/com/navercorp/pinpoint/collector/cluster/GrpcAgentConnection.java

@@ -14,11 +14,10 @@
  * limitations under the License.
  */
 
-package com.navercorp.pinpoint.collector.cluster.grpc;
+package com.navercorp.pinpoint.collector.cluster;
 
 import com.google.protobuf.GeneratedMessageV3;
-import com.navercorp.pinpoint.collector.cluster.ClusterPoint;
-import com.navercorp.pinpoint.collector.cluster.SupportedCommandUtils;
+import com.navercorp.pinpoint.collector.cluster.grpc.CommandThriftToGrpcMessageConverter;
 import com.navercorp.pinpoint.collector.receiver.grpc.PinpointGrpcServer;
 import com.navercorp.pinpoint.common.server.cluster.ClusterKey;
 import com.navercorp.pinpoint.rpc.PinpointSocketException;

collector/src/main/java/com/navercorp/pinpoint/collector/cluster/route/DefaultRouteHandler.java

@@ -18,8 +18,8 @@
 
 import com.navercorp.pinpoint.collector.cluster.ClusterPoint;
 import com.navercorp.pinpoint.collector.cluster.ClusterPointLocator;
+import com.navercorp.pinpoint.collector.cluster.GrpcAgentConnection;
 import com.navercorp.pinpoint.collector.cluster.ThriftAgentConnection;
-import com.navercorp.pinpoint.collector.cluster.grpc.GrpcAgentConnection;
 import com.navercorp.pinpoint.collector.cluster.route.filter.RouteFilter;
 import com.navercorp.pinpoint.rpc.ResponseMessage;
 import com.navercorp.pinpoint.thrift.dto.command.TCommandTransferResponse;

collector/src/main/java/com/navercorp/pinpoint/collector/cluster/route/StreamRouteHandler.java

@@ -18,8 +18,8 @@
 
 import com.navercorp.pinpoint.collector.cluster.ClusterPoint;
 import com.navercorp.pinpoint.collector.cluster.ClusterPointLocator;
+import com.navercorp.pinpoint.collector.cluster.GrpcAgentConnection;
 import com.navercorp.pinpoint.collector.cluster.ThriftAgentConnection;
-import com.navercorp.pinpoint.collector.cluster.grpc.GrpcAgentConnection;
 import com.navercorp.pinpoint.collector.cluster.route.filter.RouteFilter;
 import com.navercorp.pinpoint.rpc.packet.stream.StreamClosePacket;
 import com.navercorp.pinpoint.rpc.packet.stream.StreamCode;

collector/src/main/java/com/navercorp/pinpoint/collector/controller/ClusterPointController.java

@@ -20,7 +20,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.navercorp.pinpoint.collector.cluster.ClusterPoint;
 import com.navercorp.pinpoint.collector.cluster.ClusterPointLocator;
-import com.navercorp.pinpoint.collector.cluster.grpc.GrpcAgentConnection;
+import com.navercorp.pinpoint.collector.cluster.GrpcAgentConnection;
 import com.navercorp.pinpoint.collector.receiver.grpc.PinpointGrpcServer;
 import com.navercorp.pinpoint.common.server.cluster.ClusterKey;
 import com.navercorp.pinpoint.common.util.Assert;

collector/src/main/java/com/navercorp/pinpoint/collector/receiver/grpc/PinpointGrpcServer.java

@@ -18,8 +18,8 @@
 
 import com.google.protobuf.Empty;
 import com.google.protobuf.GeneratedMessageV3;
+import com.navercorp.pinpoint.collector.cluster.GrpcAgentConnection;
 import com.navercorp.pinpoint.collector.cluster.ProfilerClusterManager;
-import com.navercorp.pinpoint.collector.cluster.grpc.GrpcAgentConnection;
 import com.navercorp.pinpoint.common.server.cluster.ClusterKey;
 import com.navercorp.pinpoint.grpc.MessageFormatUtils;
 import com.navercorp.pinpoint.grpc.trace.PCmdActiveThreadCount;

profiler-thrift/src/main/java/com/navercorp/pinpoint/profiler/thrift/sender/message/ThreadDumpThriftMessageConverter.java

@@ -27,7 +27,7 @@
  * @author jaehong.kim
  */
 public class ThreadDumpThriftMessageConverter implements MessageConverter<Object, TThreadDump> {
-    private final ThreadStateThriftMessageConverter threadStateMessageConverter = new ThreadStateThriftMessageConverter();
+    private final MessageConverter<Object, TThreadState> threadStateMessageConverter = new ThreadStateThriftMessageConverter();
 
     @Override
     public TThreadDump toMessage(Object message) {