fix enhance undertow runnable logic

dromara · Sep 9, 2024 · 61f195a · 61f195a
1 parent 566f728
commit 61f195a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/.../org/dromara/dynamictp/starter/adapter/webserver/undertow/EnhancedQueueExecutorProxy.java b/.../org/dromara/dynamictp/starter/adapter/webserver/undertow/EnhancedQueueExecutorProxy.java
@@ -54,15 +54,15 @@ public EnhancedQueueExecutorProxy(final EnhancedQueueExecutor executor) {
 
     @Override
     public void execute(Runnable runnable) {
-        Runnable enhancedTask = EnhancedRunnable.of(getEnhancedTask(runnable), this);
-        AwareManager.execute(this, enhancedTask);
+        Runnable dtpRunnable = getEnhancedTask(runnable);
+        AwareManager.execute(this, dtpRunnable);
         try {
-            super.execute(enhancedTask);
+            super.execute(EnhancedRunnable.of(dtpRunnable, this));
         } catch (Throwable e) {
             Throwable[] suppressedExceptions = e.getSuppressed();
             for (Throwable t : suppressedExceptions) {
                 if (t instanceof RejectedExecutionException) {
-                    AwareManager.beforeReject(enhancedTask, this);
+                    AwareManager.beforeReject(dtpRunnable, this);
                     return;
                 }
             }

diff --git a/...ain/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/UndertowDtpAdapter.java b/...ain/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/UndertowDtpAdapter.java
@@ -79,7 +79,7 @@ public void doEnhance(WebServer webServer) {
                 putAndFinalize(tpName, (ExecutorService) executor, new EnhancedQueueExecutorAdapter(proxy));
             } catch (Throwable t) {
                 log.error("DynamicTp adapter, enhance {} failed, please adjust the order of the two dependencies" +
-                        "(starter-undertow and starter-adapter-webserver) and try again.", tpName, t);
+                        "(spring-boot-starter-undertow and starter-adapter-webserver) and try again.", tpName, t);
                 executors.put(tpName, new ExecutorWrapper(tpName, handler.adapt(executor)));
             }
         } else {