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

emeroad · May 17, 2023 · fef0848 · fef0848
1 parent 8d18b76
commit fef0848
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 88 deletions.
diff --git a/...ava/com/navercorp/pinpoint/common/profiler/concurrent/executor/AsyncQueueingExecutor.java b/...ava/com/navercorp/pinpoint/common/profiler/concurrent/executor/AsyncQueueingExecutor.java
@@ -61,7 +61,7 @@ public AsyncQueueingExecutor(int queueSize, String executorName, AsyncQueueingEx
         this.executeThread = this.createExecuteThread(executorName);
         this.executorName = executeThread.getName();
 
-        this.listener = Objects.requireNonNull(listener, "consumer");
+        this.listener = Objects.requireNonNull(listener, "listener");
     }
 
     private Thread createExecuteThread(String executorName) {

diff --git a/...er/src/main/java/com/navercorp/pinpoint/common/profiler/concurrent/executor/Consumer.java b/...er/src/main/java/com/navercorp/pinpoint/common/profiler/concurrent/executor/Consumer.java
diff --git a/...er/concurrent/executor/EmptyConsumer.java → ...r/EmptyAsyncQueueingExecutorListener.java b/...er/concurrent/executor/EmptyConsumer.java → ...r/EmptyAsyncQueueingExecutorListener.java
@@ -24,21 +24,21 @@
 /**
  * @author emeroad
  */
-public class EmptyConsumer<T> implements Consumer<T> {
+public class EmptyAsyncQueueingExecutorListener<T> implements AsyncQueueingExecutorListener<T> {
 
     private final Logger logger = LogManager.getLogger(this.getClass());
 
     private final boolean isDebug = logger.isDebugEnabled();
 
     @Override
-    public void acceptN(Collection<T> dtoList) {
+    public void execute(Collection<T> dtoList) {
         if (isDebug) {
-            logger.debug("execute()");
+            logger.debug("execute(N)");
         }
     }
 
     @Override
-    public void accept(T dto) {
+    public void execute(T dto) {
         if (isDebug) {
             logger.debug("execute()");
         }

diff --git a/.../main/java/com/navercorp/pinpoint/common/profiler/concurrent/executor/SimpleConsumer.java b/.../main/java/com/navercorp/pinpoint/common/profiler/concurrent/executor/SimpleConsumer.java
diff --git a/...ava/com/navercorp/pinpoint/common/profiler/concurrent/executor/UnsafeArrayCollection.java b/...ava/com/navercorp/pinpoint/common/profiler/concurrent/executor/UnsafeArrayCollection.java
@@ -31,7 +31,6 @@ public UnsafeArrayCollection(int maxSize) {
         this.array = new Object[maxSize];
     }
 
-
     @Override
     public boolean add(E o) {
         if (array.length < size) {