Browse Source

SocketIOServer#stop causes NPE. Issue #70

master
Nikita 12 years ago
parent
commit
5ec3e29d42
  1. 5
      src/main/java/com/corundumstudio/socketio/SocketIOClient.java
  2. 8
      src/main/java/com/corundumstudio/socketio/SocketIOServer.java

5
src/main/java/com/corundumstudio/socketio/SocketIOClient.java

@ -21,6 +21,11 @@ import java.util.UUID;
import com.corundumstudio.socketio.parser.Packet; import com.corundumstudio.socketio.parser.Packet;
/**
* SocketIO client abstraction.
* All implementations are thread-safe.
*
*/
public interface SocketIOClient extends ClientOperations { public interface SocketIOClient extends ClientOperations {
/** /**

8
src/main/java/com/corundumstudio/socketio/SocketIOServer.java

@ -93,8 +93,7 @@ public class SocketIOServer implements ClientListeners {
* Start server * Start server
*/ */
public void start() { public void start() {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
initGroups();
pipelineFactory.start(configCopy, namespacesHub); pipelineFactory.start(configCopy, namespacesHub);
ServerBootstrap b = new ServerBootstrap(); ServerBootstrap b = new ServerBootstrap();
@ -113,6 +112,11 @@ public class SocketIOServer implements ClientListeners {
log.info("SocketIO server started at port: {}", configCopy.getPort()); log.info("SocketIO server started at port: {}", configCopy.getPort());
} }
protected void initGroups() {
bossGroup = new NioEventLoopGroup(configCopy.getBossThreads());
workerGroup = new NioEventLoopGroup(configCopy.getWorkerThreads());
}
/** /**
* Stop server * Stop server
*/ */

Loading…
Cancel
Save