diff options
Diffstat (limited to 'java/broker/src')
| -rw-r--r-- | java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java | 16 |
1 files changed, 3 insertions, 13 deletions
diff --git a/java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java b/java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java index e9e9c8aca4..6470d876bb 100644 --- a/java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java +++ b/java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java @@ -19,6 +19,8 @@ package org.apache.qpid.server.transport; import org.apache.qpid.configuration.Configured; import org.apache.mina.common.IoAcceptor; +import org.apache.mina.filter.executor.ExecutorExecutor; +import org.apache.mina.util.NewThreadExecutor; public class ConnectorConfiguration { @@ -74,20 +76,8 @@ public class ConnectorConfiguration defaultValue = "true") public boolean enableNonSSL; - @Configured(path = "advanced.useBlockingIo", - defaultValue = "false") - public boolean useBlockingIo; - public IoAcceptor createAcceptor() { - if(useBlockingIo) - { - System.out.println("Using blocking io"); - return new org.apache.qpid.bio.SocketAcceptor(); - } - else - { - return new org.apache.mina.transport.socket.nio.SocketAcceptor(processors); - } + return new org.apache.mina.transport.socket.nio.SocketAcceptor(processors, new NewThreadExecutor()); } } |