Browse Source

Minor class rename

master
Nikita 12 years ago
parent
commit
b4070e91c9
  1. 2
      src/main/java/com/corundumstudio/socketio/SocketIOChannelInitializer.java
  2. 4
      src/main/java/com/corundumstudio/socketio/SocketIOServer.java
  3. 4
      src/main/java/com/corundumstudio/socketio/transport/FlashSocketTransport.java
  4. 4
      src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java

2
src/main/java/com/corundumstudio/socketio/SocketIOPipelineFactory.java → src/main/java/com/corundumstudio/socketio/SocketIOChannelInitializer.java

@ -52,7 +52,7 @@ import com.corundumstudio.socketio.transport.FlashSocketTransport;
import com.corundumstudio.socketio.transport.WebSocketTransport;
import com.corundumstudio.socketio.transport.XHRPollingTransport;
public class SocketIOPipelineFactory extends ChannelInitializer<Channel> implements DisconnectableHub {
public class SocketIOChannelInitializer extends ChannelInitializer<Channel> implements DisconnectableHub {
public static final String SOCKETIO_ENCODER = "socketioEncoder";
public static final String WEB_SOCKET_TRANSPORT = "webSocketTransport";

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

@ -44,7 +44,7 @@ public class SocketIOServer implements ClientListeners {
private final NamespacesHub namespacesHub;
private final SocketIONamespace mainNamespace;
private SocketIOPipelineFactory pipelineFactory = new SocketIOPipelineFactory();
private SocketIOChannelInitializer pipelineFactory = new SocketIOChannelInitializer();
private EventLoopGroup bossGroup;
private EventLoopGroup workerGroup;
@ -56,7 +56,7 @@ public class SocketIOServer implements ClientListeners {
mainNamespace = addNamespace(Namespace.DEFAULT_NAME);
}
public void setPipelineFactory(SocketIOPipelineFactory pipelineFactory) {
public void setPipelineFactory(SocketIOChannelInitializer pipelineFactory) {
this.pipelineFactory = pipelineFactory;
}

4
src/main/java/com/corundumstudio/socketio/transport/FlashSocketTransport.java

@ -21,7 +21,7 @@ import io.netty.channel.ChannelHandler.Sharable;
import com.corundumstudio.socketio.DisconnectableHub;
import com.corundumstudio.socketio.HeartbeatHandler;
import com.corundumstudio.socketio.SocketIOPipelineFactory;
import com.corundumstudio.socketio.SocketIOChannelInitializer;
import com.corundumstudio.socketio.Transport;
import com.corundumstudio.socketio.ack.AckManager;
import com.corundumstudio.socketio.handler.AuthorizeHandler;
@ -45,7 +45,7 @@ public class FlashSocketTransport extends WebSocketTransport {
@Override
protected void removeHandler(ChannelPipeline pipeline) {
pipeline.remove(SocketIOPipelineFactory.WEB_SOCKET_TRANSPORT);
pipeline.remove(SocketIOChannelInitializer.WEB_SOCKET_TRANSPORT);
}
}

4
src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java

@ -41,7 +41,7 @@ import org.slf4j.LoggerFactory;
import com.corundumstudio.socketio.DisconnectableHub;
import com.corundumstudio.socketio.HeartbeatHandler;
import com.corundumstudio.socketio.SocketIOClient;
import com.corundumstudio.socketio.SocketIOPipelineFactory;
import com.corundumstudio.socketio.SocketIOChannelInitializer;
import com.corundumstudio.socketio.Transport;
import com.corundumstudio.socketio.ack.AckManager;
import com.corundumstudio.socketio.handler.AuthorizeHandler;
@ -166,7 +166,7 @@ public class WebSocketTransport extends BaseTransport {
}
protected void removeHandler(ChannelPipeline pipeline) {
pipeline.remove(SocketIOPipelineFactory.FLASH_SOCKET_TRANSPORT);
pipeline.remove(SocketIOChannelInitializer.FLASH_SOCKET_TRANSPORT);
}
private String getWebSocketLocation(HttpRequest req) {

Loading…
Cancel
Save