diff options
Diffstat (limited to 'java')
| -rw-r--r-- | java/broker/src/org/apache/qpid/server/Main.java | 14 |
1 files changed, 1 insertions, 13 deletions
diff --git a/java/broker/src/org/apache/qpid/server/Main.java b/java/broker/src/org/apache/qpid/server/Main.java index d6433bf895..d2dacb6140 100644 --- a/java/broker/src/org/apache/qpid/server/Main.java +++ b/java/broker/src/org/apache/qpid/server/Main.java @@ -320,19 +320,7 @@ public class Main implements ProtocolVersionList SocketSessionConfig sc; - //fixme improve get to use configuration - if (connectorConfig.qpidNIO) - { - //FIXME - this needs to be sorted to use the new Mina MultiThread SA. - _logger.warn("Using Qpid NIO - DISABLED"); - //sconfig = (org.apache.mina.transport.socket.nio.MultiThreadSocketAcceptorConfig) acceptor.getDefaultConfig(); - //sc = (SocketSessionConfig) sconfig.getSessionConfig(); - } -// else - { - _logger.warn("Using Mina NIO"); - sc = (SocketSessionConfig) acceptor.getSessionConfig(); - } + sc = (SocketSessionConfig) acceptor.getSessionConfig(); sc.setReceiveBufferSize(connectorConfig.socketReceiveBufferSize); sc.setSendBufferSize(connectorConfig.socketWriteBuferSize); |