[rocketmq-exporter] branch master updated: Remove valueless broker package dependency

[vo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

vongosling pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/master by this push:
     new c96d170  Remove valueless broker package dependency
c96d170 is described below

commit c96d170a0141c2879fc6410d085edd9ad092c60e
Author: von gosling <vo...@apache.org>
AuthorDate: Wed Dec 30 16:55:08 2020 +0800

    Remove valueless broker package dependency
---
 .../task/ClientMetricCollectorFixedThreadPoolExecutor.java         | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/main/java/org/apache/rocketmq/exporter/task/ClientMetricCollectorFixedThreadPoolExecutor.java b/src/main/java/org/apache/rocketmq/exporter/task/ClientMetricCollectorFixedThreadPoolExecutor.java
index 7b579ac..3ac8656 100644
--- a/src/main/java/org/apache/rocketmq/exporter/task/ClientMetricCollectorFixedThreadPoolExecutor.java
+++ b/src/main/java/org/apache/rocketmq/exporter/task/ClientMetricCollectorFixedThreadPoolExecutor.java
@@ -16,14 +16,13 @@
  */
 package org.apache.rocketmq.exporter.task;
 
-import org.apache.rocketmq.broker.latency.FutureTaskExt;
-
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.RejectedExecutionHandler;
 import java.util.concurrent.RunnableFuture;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.FutureTask;
 
 public class ClientMetricCollectorFixedThreadPoolExecutor extends ThreadPoolExecutor {
     public ClientMetricCollectorFixedThreadPoolExecutor(int corePoolSize, int maximumPoolSize,
@@ -35,6 +34,6 @@ public class ClientMetricCollectorFixedThreadPoolExecutor extends ThreadPoolExec
 
 
     protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {
-        return new FutureTaskExt(runnable, value);
+        return new FutureTask(runnable, value);
     }
-}
\ No newline at end of file
+}