[camel] 01/02: Remove changing thread name which leads to very verbose output also, thanks to Jason Dillon for reporting on gitter chat

[davsclaus]

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

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 163e1f4348952a6c54ec62f1832e382d1ee9c02b
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Jun 22 14:19:30 2019 +0200

    Remove changing thread name which leads to very verbose output also, thanks 
to Jason Dillon for reporting on gitter chat
---
 .../apache/camel/impl/engine/DefaultReactiveExecutor.java   | 13 +++----------
 1 file changed, 3 insertions(+), 10 deletions(-)

diff --git 
a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java
 
b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java
index 17f69e7..c441e34 100644
--- 
a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java
+++ 
b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java
@@ -166,8 +166,6 @@ public class DefaultReactiveExecutor extends ServiceSupport 
implements ReactiveE
             if (!running || sync) {
                 running = true;
                 executor.runningWorkers.incrementAndGet();
-//                Thread thread = Thread.currentThread();
-//                String name = thread.getName();
                 try {
                     for (;;) {
                         final Runnable polled = queue.poll();
@@ -181,7 +179,6 @@ public class DefaultReactiveExecutor extends ServiceSupport 
implements ReactiveE
                         }
                         try {
                             executor.pendingTasks.decrementAndGet();
-//                            thread.setName(name + " - " + polled.toString());
                             if (LOG.isTraceEnabled()) {
                                 LOG.trace("Running: {}", runnable);
                             }
@@ -191,12 +188,13 @@ public class DefaultReactiveExecutor extends 
ServiceSupport implements ReactiveE
                         }
                     }
                 } finally {
-//                    thread.setName(name);
                     running = false;
                     executor.runningWorkers.decrementAndGet();
                 }
             } else {
-                LOG.debug("Queuing reactive work: {}", runnable);
+                if (LOG.isDebugEnabled()) {
+                    LOG.debug("Queuing reactive work: {}", runnable);
+                }
             }
         }
 
@@ -205,11 +203,8 @@ public class DefaultReactiveExecutor extends 
ServiceSupport implements ReactiveE
             if (polled == null) {
                 return false;
             }
-            Thread thread = Thread.currentThread();
-            String name = thread.getName();
             try {
                 executor.pendingTasks.decrementAndGet();
-                thread.setName(name + " - " + polled.toString());
                 if (LOG.isTraceEnabled()) {
                     LOG.trace("Running: {}", polled);
                 }
@@ -217,8 +212,6 @@ public class DefaultReactiveExecutor extends ServiceSupport 
implements ReactiveE
             } catch (Throwable t) {
                 // should not happen
                 LOG.warn("Error executing reactive work due to " + 
t.getMessage() + ". This exception is ignored.", t);
-            } finally {
-                thread.setName(name);
             }
             return true;
         }