Deprected iothread restriction on acceptor, using default

Author: mondain

pom.xml

@@ -9,7 +9,7 @@
     <artifactId>websocket</artifactId>
     <packaging>jar</packaging>
     <name>websocket</name>
-    <version>1.16.0</version>
+    <version>1.16.2</version>
     <description>Red5 WebSocket plugin</description>
     <url>https://github.com/Red5/red5-websocket</url>
     <organization>

src/main/java/org/red5/net/websocket/WebSocketConnection.java

@@ -26,6 +26,7 @@
 import java.util.Optional;
 import java.util.concurrent.atomic.AtomicBoolean;
 
+import org.apache.commons.lang3.StringUtils;
 import org.apache.mina.core.buffer.IoBuffer;
 import org.apache.mina.core.future.CloseFuture;
 import org.apache.mina.core.future.IoFutureListener;
@@ -139,14 +140,17 @@ public void receive(WSMessage message) {
     /**
      * Sends text to the client.
      * 
-     * @param data
-     *            string data
+     * @param data string data
      * @throws UnsupportedEncodingException
      */
     public void send(String data) throws UnsupportedEncodingException {
         log.trace("send message: {}", data);
-        Packet packet = Packet.build(data.getBytes("UTF8"), MessageType.TEXT);
-        session.write(packet);
+        if (StringUtils.isNotBlank(data)) {
+            Packet packet = Packet.build(data.getBytes("UTF8"), MessageType.TEXT);
+            session.write(packet);
+        } else {
+            throw new UnsupportedEncodingException("Cannot send a null string");
+        }
     }
 
     /**

src/main/java/org/red5/net/websocket/WebSocketTransport.java

@@ -55,11 +55,6 @@ public class WebSocketTransport implements InitializingBean, DisposableBean {
 
     private int receiveBufferSize = 2048;
 
-    @SuppressWarnings("unused")
-    private int connectionThreads = 8;
-
-    private int ioThreads = 16;
-
     private int port = 80;
 
     private Set<String> addresses = new HashSet<>();
@@ -87,7 +82,7 @@ public class WebSocketTransport implements InitializingBean, DisposableBean {
     @Override
     public void afterPropertiesSet() throws Exception {
         // create the nio acceptor
-        acceptor = new NioSocketAcceptor(ioThreads);
+        acceptor = new NioSocketAcceptor();
         // configure the acceptor
         SocketSessionConfig sessionConf = acceptor.getSessionConfig();
         sessionConf.setReuseAddress(true);
@@ -197,19 +192,17 @@ public void setReceiveBufferSize(int receiveBufferSize) {
     }
 
     /**
-     * @param connectionThreads
-     *            the connectionThreads to set
+     * @param connectionThreads the connectionThreads to set
      */
+    @Deprecated
     public void setConnectionThreads(int connectionThreads) {
-        this.connectionThreads = connectionThreads;
     }
 
     /**
-     * @param ioThreads
-     *            the ioThreads to set
+     * @param ioThreads the ioThreads to set
      */
+    @Deprecated
     public void setIoThreads(int ioThreads) {
-        this.ioThreads = ioThreads;
     }
 
     public boolean isSecure() {