JAMES-1772 Name thread pools of AsyncServers
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/606120d2 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/606120d2 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/606120d2 Branch: refs/heads/master Commit: 606120d26a43fa6eaa6f50a08b509e0aca9d19e8 Parents: a2bb720 Author: Matthieu Baechler <[email protected]> Authored: Wed Jun 8 21:45:06 2016 +0200 Committer: Raphael Ouazana <[email protected]> Committed: Tue Jun 21 10:36:13 2016 +0200 ---------------------------------------------------------------------- .../protocols/lib/netty/AbstractConfigurableAsyncServer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/606120d2/server/protocols/protocols-library/src/main/java/org/apache/james/protocols/lib/netty/AbstractConfigurableAsyncServer.java ---------------------------------------------------------------------- diff --git a/server/protocols/protocols-library/src/main/java/org/apache/james/protocols/lib/netty/AbstractConfigurableAsyncServer.java b/server/protocols/protocols-library/src/main/java/org/apache/james/protocols/lib/netty/AbstractConfigurableAsyncServer.java index 1d2dd05..4575172 100644 --- a/server/protocols/protocols-library/src/main/java/org/apache/james/protocols/lib/netty/AbstractConfigurableAsyncServer.java +++ b/server/protocols/protocols-library/src/main/java/org/apache/james/protocols/lib/netty/AbstractConfigurableAsyncServer.java @@ -466,12 +466,12 @@ public abstract class AbstractConfigurableAsyncServer extends AbstractAsyncServe @Override protected Executor createBossExecutor() { - return JMXEnabledThreadPoolExecutor.newCachedThreadPool(getThreadPoolJMXPath(), "boss"); + return JMXEnabledThreadPoolExecutor.newCachedThreadPool(getThreadPoolJMXPath(), getDefaultJMXName() + "-boss"); } @Override protected Executor createWorkerExecutor() { - return JMXEnabledThreadPoolExecutor.newCachedThreadPool(getThreadPoolJMXPath(), "worker"); + return JMXEnabledThreadPoolExecutor.newCachedThreadPool(getThreadPoolJMXPath(), getDefaultJMXName() + "-worker"); } /** @@ -561,7 +561,7 @@ public abstract class AbstractConfigurableAsyncServer extends AbstractAsyncServe * @return ehandler */ protected ExecutionHandler createExecutionHander() { - return new ExecutionHandler(new JMXEnabledOrderedMemoryAwareThreadPoolExecutor(maxExecutorThreads, 0, 0, getThreadPoolJMXPath(), "executor")); + return new ExecutionHandler(new JMXEnabledOrderedMemoryAwareThreadPoolExecutor(maxExecutorThreads, 0, 0, getThreadPoolJMXPath(), getDefaultJMXName() + "-executor")); } /** --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
