diff --git a/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocketFactory.java b/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocketFactory.java index a92e9b5ea..b0f3c0463 100644 --- a/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocketFactory.java +++ b/src/main/java/com/nhn/pinpoint/rpc/client/PinpointSocketFactory.java @@ -51,7 +51,7 @@ public class PinpointSocketFactory { } private Timer createTimer() { - ThreadFactory threadFactory = new PinpointThreadFactory(this.getClass().getSimpleName() + "Timer"); + ThreadFactory threadFactory = new PinpointThreadFactory(this.getClass().getSimpleName() + "Timer", true); HashedWheelTimer timer = new HashedWheelTimer(threadFactory, 100, TimeUnit.MILLISECONDS); timer.start(); return timer; diff --git a/src/main/java/com/nhn/pinpoint/rpc/client/RequestManager.java b/src/main/java/com/nhn/pinpoint/rpc/client/RequestManager.java index b69e14791..ea79b36cf 100644 --- a/src/main/java/com/nhn/pinpoint/rpc/client/RequestManager.java +++ b/src/main/java/com/nhn/pinpoint/rpc/client/RequestManager.java @@ -28,7 +28,7 @@ import java.util.concurrent.atomic.AtomicInteger; public class RequestManager { private final Logger logger = LoggerFactory.getLogger(this.getClass()); - private static final ThreadFactory THREAD_FACTORY = new PinpointThreadFactory("RequestManager-Timer"); + private static final ThreadFactory THREAD_FACTORY = new PinpointThreadFactory("RequestManager-Timer", true); private final AtomicInteger requestId = new AtomicInteger(1);