@ -29,7 +29,7 @@ import com.corundumstudio.socketio.protocol.JsonSupport;
class JsonSupportWrapper implements JsonSupport {
private final Logger log = LoggerFactory.getLogger(getClass());
private static final Logger log = LoggerFactory.getLogger(JsonSupportWrapper.class);
private final JsonSupport delegate;
@ -72,7 +72,7 @@ public class SocketIOChannelInitializer extends ChannelInitializer<Channel> impl
public static final String RESOURCE_HANDLER = "resourceHandler";
public static final String WRONG_URL_HANDLER = "wrongUrlBlocker";
private static final Logger log = LoggerFactory.getLogger(SocketIOChannelInitializer.class);
private AckManager ackManager;
@ -47,7 +47,7 @@ import com.corundumstudio.socketio.namespace.NamespacesHub;
*/
public class SocketIOServer implements ClientListeners {
private static final Logger log = LoggerFactory.getLogger(SocketIOServer.class);
private final Configuration configCopy;
private final Configuration configuration;
@ -69,7 +69,7 @@ public class AckManager implements Disconnectable {
}
private static final Logger log = LoggerFactory.getLogger(AckManager.class);
private final Map<UUID, AckEntry> ackEntries = PlatformDependent.newConcurrentHashMap();
@ -28,7 +28,7 @@ import com.corundumstudio.socketio.namespace.Namespace;
public class ScannerEngine {
private static final Logger log = LoggerFactory.getLogger(ScannerEngine.class);
private static final List<? extends AnnotationScanner> annotations =
Arrays.asList(new OnConnectScanner(), new OnDisconnectScanner(), new OnEventScanner());
@ -33,7 +33,7 @@ import com.corundumstudio.socketio.SocketIOServer;
public class SpringAnnotationScanner implements BeanPostProcessor {
private static final Logger log = LoggerFactory.getLogger(SpringAnnotationScanner.class);
private final List<Class<? extends Annotation>> annotations =
Arrays.asList(OnConnect.class, OnDisconnect.class, OnEvent.class);
@ -61,7 +61,7 @@ import com.corundumstudio.socketio.store.pubsub.PubSubStore;
@Sharable
public class AuthorizeHandler extends ChannelInboundHandlerAdapter implements Disconnectable {
private static final Logger log = LoggerFactory.getLogger(AuthorizeHandler.class);
private final CancelableScheduler disconnectScheduler;
@ -55,7 +55,7 @@ import com.corundumstudio.socketio.transport.NamespaceClient;
public class ClientHead {
private static final Logger log = LoggerFactory.getLogger(ClientHead.class);
public static final AttributeKey<ClientHead> CLIENT = AttributeKey.<ClientHead>valueOf("client");
@ -73,7 +73,7 @@ public class EncoderHandler extends ChannelOutboundHandlerAdapter {
public static final AttributeKey<Integer> JSONP_INDEX = AttributeKey.valueOf("jsonpIndex");
public static final AttributeKey<Boolean> WRITE_ONCE = AttributeKey.valueOf("writeOnce");
private static final Logger log = LoggerFactory.getLogger(EncoderHandler.class);
private final PacketEncoder encoder;
@ -36,7 +36,7 @@ import com.corundumstudio.socketio.transport.NamespaceClient;
public class InPacketHandler extends SimpleChannelInboundHandler<PacketsMessage> {
private static final Logger log = LoggerFactory.getLogger(InPacketHandler.class);
private final PacketListener packetListener;
private final PacketDecoder decoder;
@ -60,7 +60,7 @@ import com.corundumstudio.socketio.SocketIOChannelInitializer;
public class ResourceHandler extends ChannelInboundHandlerAdapter {
private static final Logger log = LoggerFactory.getLogger(ResourceHandler.class);
public static final String HTTP_DATE_FORMAT = "EEE, dd MMM yyyy HH:mm:ss zzz";
public static final String HTTP_DATE_GMT_TIMEZONE = "GMT";
@ -35,7 +35,7 @@ import io.netty.handler.codec.http.QueryStringDecoder;
public class WrongUrlHandler extends ChannelInboundHandlerAdapter {
private static final Logger log = LoggerFactory.getLogger(WrongUrlHandler.class);
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
if (msg instanceof FullHttpRequest) {
@ -26,7 +26,7 @@ import com.corundumstudio.socketio.SocketIOClient;
public class DefaultExceptionListener extends ExceptionListenerAdapter {
private static final Logger log = LoggerFactory.getLogger(DefaultExceptionListener.class);
@Override
public void onEventException(Exception e, List<Object> args, SocketIOClient client) {
@ -295,7 +295,7 @@ public class JacksonJsonSupport implements JsonSupport {
private final EventDeserializer eventDeserializer = new EventDeserializer();
private final AckArgsDeserializer ackArgsDeserializer = new AckArgsDeserializer();
private static final Logger log = LoggerFactory.getLogger(JacksonJsonSupport.class);
public JacksonJsonSupport() {
this(new Module[] {});
@ -35,7 +35,7 @@ import com.corundumstudio.socketio.protocol.PacketType;
public class NamespaceClient implements SocketIOClient {
private static final Logger log = LoggerFactory.getLogger(NamespaceClient.class);
private final AtomicBoolean disconnected = new AtomicBoolean();
private final ClientHead baseClient;
@ -51,7 +51,7 @@ public class PollingTransport extends ChannelInboundHandlerAdapter {
public static final String NAME = "polling";
private static final Logger log = LoggerFactory.getLogger(PollingTransport.class);
private final ClientsBox clientsBox;
@ -56,7 +56,7 @@ public class WebSocketTransport extends ChannelInboundHandlerAdapter {
public static final String NAME = "websocket";
private static final Logger log = LoggerFactory.getLogger(WebSocketTransport.class);
private final AuthorizeHandler authorizeHandler;
private final CancelableScheduler scheduler;