fix: new scheduled thread pool proxy should set reject handler from the origin

kvchoi · kvchoi · commit f055c0158bb8 · 2025-02-05T11:04:28.000+08:00
diff --git a/core/src/main/java/org/dromara/dynamictp/core/support/proxy/ScheduledThreadPoolExecutorProxy.java b/core/src/main/java/org/dromara/dynamictp/core/support/proxy/ScheduledThreadPoolExecutorProxy.java
@@ -52,7 +52,7 @@ public class ScheduledThreadPoolExecutorProxy extends ScheduledThreadPoolExecuto
     public ScheduledThreadPoolExecutorProxy(ScheduledThreadPoolExecutor executor) {
         super(executor.getCorePoolSize(), executor.getThreadFactory());
         this.rejectHandlerType = executor.getRejectedExecutionHandler().getClass().getSimpleName();
-        setRejectedExecutionHandler(RejectHandlerGetter.getProxy(getRejectedExecutionHandler()));
+        setRejectedExecutionHandler(RejectHandlerGetter.getProxy(executor.getRejectedExecutionHandler()));
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ public class ScheduledThreadPoolExecutorProxy extends ScheduledThreadPoolExecuto`
`52`	`52`	`public ScheduledThreadPoolExecutorProxy(ScheduledThreadPoolExecutor executor) {`
`53`	`53`	`super(executor.getCorePoolSize(), executor.getThreadFactory());`
`54`	`54`	`this.rejectHandlerType = executor.getRejectedExecutionHandler().getClass().getSimpleName();`
`55`		`- setRejectedExecutionHandler(RejectHandlerGetter.getProxy(getRejectedExecutionHandler()));`
	`55`	`+ setRejectedExecutionHandler(RejectHandlerGetter.getProxy(executor.getRejectedExecutionHandler()));`
`56`	`56`	`}`
`57`	`57`
`58`	`58`	`@Override`