Browse Source

Issue #6 fixed

master
Nikita 13 years ago
parent
commit
cad090f8da
  1. 9
      src/main/java/com/corundumstudio/socketio/Configuration.java
  2. 3
      src/main/java/com/corundumstudio/socketio/SocketIOPipelineFactory.java

9
src/main/java/com/corundumstudio/socketio/Configuration.java

@ -22,6 +22,8 @@ import org.codehaus.jackson.map.ObjectMapper;
public class Configuration { public class Configuration {
private String context = "/socket.io";
private Executor bossExecutor = Executors.newCachedThreadPool(); private Executor bossExecutor = Executors.newCachedThreadPool();
private Executor workerExecutor = Executors.newCachedThreadPool(); private Executor workerExecutor = Executors.newCachedThreadPool();
@ -148,4 +150,11 @@ public class Configuration {
return closeTimeout; return closeTimeout;
} }
public String getContext() {
return context;
}
public void setContext(String context) {
this.context = context;
}
} }

3
src/main/java/com/corundumstudio/socketio/SocketIOPipelineFactory.java

@ -36,7 +36,6 @@ public class SocketIOPipelineFactory implements ChannelPipelineFactory, Disconne
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
private final int protocol = 1; private final int protocol = 1;
private final String connectPath = "/socket.io/" + protocol + "/";
private final AuthorizeHandler authorizeHandler; private final AuthorizeHandler authorizeHandler;
private XHRPollingTransport xhrPollingTransport; private XHRPollingTransport xhrPollingTransport;
@ -57,6 +56,8 @@ public class SocketIOPipelineFactory implements ChannelPipelineFactory, Disconne
Decoder decoder = new Decoder(objectMapper); Decoder decoder = new Decoder(objectMapper);
PacketListener packetListener = new PacketListener(socketIOHandler, this, heartbeatHandler); PacketListener packetListener = new PacketListener(socketIOHandler, this, heartbeatHandler);
String connectPath = configuration.getContext() + "/" + protocol + "/";
packetHandler = new PacketHandler(packetListener, decoder); packetHandler = new PacketHandler(packetListener, decoder);
authorizeHandler = new AuthorizeHandler(connectPath, socketIOHandler, configuration); authorizeHandler = new AuthorizeHandler(connectPath, socketIOHandler, configuration);
xhrPollingTransport = new XHRPollingTransport(connectPath, this, heartbeatHandler, authorizeHandler, configuration); xhrPollingTransport = new XHRPollingTransport(connectPath, this, heartbeatHandler, authorizeHandler, configuration);

Loading…
Cancel
Save