From 7ee5cdd276cc358dd1ca1b0284ac0715943eebfd Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Tue, 9 Mar 2010 14:05:11 +0000 Subject: [PATCH] https://issues.apache.org/activemq/browse/AMQ-2440 - fine tuning git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@920881 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/transport/nio/SelectorManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java b/activemq-core/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java index d520fa1422..9782f3b04d 100644 --- a/activemq-core/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java @@ -42,10 +42,10 @@ public final class SelectorManager { private Executor selectorExecutor = createDefaultExecutor(); private Executor channelExecutor = selectorExecutor; private LinkedList freeWorkers = new LinkedList(); - private int maxChannelsPerWorker = 64; + private int maxChannelsPerWorker = 1024; protected ExecutorService createDefaultExecutor() { - ThreadPoolExecutor rc = new ThreadPoolExecutor(0, 200, 1, TimeUnit.SECONDS, new SynchronousQueue(), new ThreadFactory() { + ThreadPoolExecutor rc = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 10, TimeUnit.MILLISECONDS, new SynchronousQueue(), new ThreadFactory() { public Thread newThread(Runnable runnable) { return new Thread(runnable, "ActiveMQ NIO Worker"); }