* {@link WebSocketClientHandler} is implementation of
* {@link SimpleChannelInboundHandler} which handle {@link TextWebSocketFrame},
* {@link PongWebSocketFrame} and {@link CloseWebSocketFrame} messages.
+ *
+ * @deprecated This code is deprecated without replacement.
*/
+@Deprecated
public class WebSocketClientHandler extends SimpleChannelInboundHandler<Object> {
- private static final Logger LOGGER = LoggerFactory
- .getLogger(WebSocketClientHandler.class.toString());
+ private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketClientHandler.class.toString());
private final WebSocketClientHandshaker handshaker;
+ private final ClientMessageCallback messageListener;
+
private ChannelPromise handshakeFuture;
- private ClientMessageCallback messageListener;
/**
* Create new Web Socket Client Handler.
*
*
*/
- public WebSocketClientHandler(WebSocketClientHandshaker handshaker,
- ClientMessageCallback listener) {
+ public WebSocketClientHandler(final WebSocketClientHandshaker handshaker, final ClientMessageCallback listener) {
this.handshaker = handshaker;
this.messageListener = listener;
}
}
@Override
- public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
+ public void handlerAdded(final ChannelHandlerContext ctx) throws Exception {
handshakeFuture = ctx.newPromise();
}
@Override
- public void channelActive(ChannelHandlerContext ctx) throws Exception {
+ public void channelActive(final ChannelHandlerContext ctx) throws Exception {
handshaker.handshake(ctx.channel());
}
@Override
- public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+ public void channelInactive(final ChannelHandlerContext ctx) throws Exception {
LOGGER.info("WebSocket Client disconnected!");
}
@Override
- public void channelRead0(ChannelHandlerContext ctx, Object msg)
+ public void channelRead0(final ChannelHandlerContext ctx, final Object msg)
throws Exception {
Channel ch = ctx.channel();
if (!handshaker.isHandshakeComplete()) {
}
@Override
- public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
+ public void exceptionCaught(final ChannelHandlerContext ctx, final Throwable cause)
throws Exception {
if (!handshakeFuture.isDone()) {
handshakeFuture.setFailure(cause);
*/
package org.opendaylight.yangtools.websocket.client;
+import com.google.common.base.Preconditions;
import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.Channel;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.handler.codec.http.websocketx.WebSocketClientHandshakerFactory;
import io.netty.handler.codec.http.websocketx.WebSocketVersion;
-
import java.net.URI;
-
import org.opendaylight.yangtools.websocket.client.callback.ClientMessageCallback;
-import com.google.common.base.Preconditions;
-
/**
* Implementation of web socket client that supports WS and HTTP protocols.
+ *
+ * @deprecated This code is deprecated without replacement.
*/
+@Deprecated
public class WebSocketIClient {
private final EventLoopGroup group = new NioEventLoopGroup();
private final Bootstrap bootstrap = new Bootstrap();
public WebSocketIClient(final URI uri, final ClientMessageCallback clientMessageCallback) {
this.uri = Preconditions.checkNotNull(uri);
clientHandler = new WebSocketClientHandler(
- WebSocketClientHandshakerFactory.newHandshaker(uri,
- WebSocketVersion.V13, null, false, null),
- clientMessageCallback); // last null could be replaced with
- // DefaultHttpHeaders
+ WebSocketClientHandshakerFactory.newHandshaker(uri, WebSocketVersion.V13, null, false, null),
+ clientMessageCallback); // last null could be replaced with DefaultHttpHeaders
initialize();
}
/**
* {@link ClientMessageCallback} notifies client that some event has occurred.
+ *
+ * @deprecated This code is deprecated without replacement.
*/
+@Deprecated
public interface ClientMessageCallback {
/**
*/
package org.opendaylight.yangtools.websocket;
+import com.google.common.util.concurrent.SettableFuture;
+import io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
import java.net.URI;
import java.net.URISyntaxException;
-
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.Assert;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
-
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
import org.opendaylight.yangtools.websocket.client.WebSocketIClient;
import org.opendaylight.yangtools.websocket.server.WebSocketServer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
-import io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
-
-import com.google.common.util.concurrent.SettableFuture;
-
+@Deprecated
public class WebSocketClientTest {
private static final Logger logger = LoggerFactory.getLogger(WebSocketClientTest.class.toString());
private static final String MESSAGE = "Take me to your leader!";
/**
* Tracks if the message from the server has been received
*/
- private SettableFuture<Boolean> messageReceived = SettableFuture.create();
+ private final SettableFuture<Boolean> messageReceived = SettableFuture.create();
/**
* Tracks the port on which the server is listening
private class ClientMessageCallback implements org.opendaylight.yangtools.websocket.client.callback.ClientMessageCallback {
@Override
- public void onMessageReceived(Object message) {
+ public void onMessageReceived(final Object message) {
logger.info("received message {}",message);
messageReceived.set(true);
}
package org.opendaylight.yangtools.websocket.server;
import com.google.common.util.concurrent.SettableFuture;
-
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
-
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
* <li>Firefox 11+ (RFC 6455 aka draft-ietf-hybi-thewebsocketprotocol-17)
* </ul>
*/
+@Deprecated
public class WebSocketServer implements Runnable {
/**
*/
package org.opendaylight.yangtools.websocket.server;
+import static io.netty.handler.codec.http.HttpHeaders.isKeepAlive;
+import static io.netty.handler.codec.http.HttpHeaders.setContentLength;
+import static io.netty.handler.codec.http.HttpHeaders.Names.HOST;
+import static io.netty.handler.codec.http.HttpMethod.GET;
+import static io.netty.handler.codec.http.HttpResponseStatus.BAD_REQUEST;
+import static io.netty.handler.codec.http.HttpResponseStatus.FORBIDDEN;
+import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
+
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.util.CharsetUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import static io.netty.handler.codec.http.HttpHeaders.Names.HOST;
-import static io.netty.handler.codec.http.HttpHeaders.isKeepAlive;
-import static io.netty.handler.codec.http.HttpHeaders.setContentLength;
-import static io.netty.handler.codec.http.HttpMethod.GET;
-import static io.netty.handler.codec.http.HttpResponseStatus.BAD_REQUEST;
-import static io.netty.handler.codec.http.HttpResponseStatus.FORBIDDEN;
-import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
/**
* Handles handshakes and messages
*/
+@Deprecated
public class WebSocketServerHandler extends SimpleChannelInboundHandler<Object> {
private static final Logger logger = LoggerFactory.getLogger(WebSocketServerHandler.class.getName());
private WebSocketServerHandshaker handshaker;
@Override
- public void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
+ public void channelRead0(final ChannelHandlerContext ctx, final Object msg) throws Exception {
if (msg instanceof FullHttpRequest) {
handleHttpRequest(ctx, (FullHttpRequest) msg);
} else if (msg instanceof WebSocketFrame) {
}
@Override
- public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+ public void channelReadComplete(final ChannelHandlerContext ctx) throws Exception {
ctx.flush();
}
- private void handleHttpRequest(ChannelHandlerContext ctx, FullHttpRequest req) throws Exception {
+ private void handleHttpRequest(final ChannelHandlerContext ctx, final FullHttpRequest req) throws Exception {
// Handle a bad request.
if (!req.getDecoderResult().isSuccess()) {
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(HTTP_1_1, BAD_REQUEST));
}
}
- private void handleWebSocketFrame(ChannelHandlerContext ctx, WebSocketFrame frame) {
+ private void handleWebSocketFrame(final ChannelHandlerContext ctx, final WebSocketFrame frame) {
// Check for closing frame
if (frame instanceof CloseWebSocketFrame) {
}
private static void sendHttpResponse(
- ChannelHandlerContext ctx, FullHttpRequest req, FullHttpResponse res) {
+ final ChannelHandlerContext ctx, final FullHttpRequest req, final FullHttpResponse res) {
// Generate an error page if response getStatus code is not OK (200).
if (res.getStatus().code() != 200) {
ByteBuf buf = Unpooled.copiedBuffer(res.getStatus().toString(), CharsetUtil.UTF_8);
}
@Override
- public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+ public void exceptionCaught(final ChannelHandlerContext ctx, final Throwable cause) throws Exception {
logger.info("Exception caught {}",cause);
ctx.close();
}
- private static String getWebSocketLocation(FullHttpRequest req) {
+ private static String getWebSocketLocation(final FullHttpRequest req) {
return "ws://" + req.headers().get(HOST) + WEBSOCKET_PATH;
}
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
-import org.opendaylight.yangtools.websocket.server.WebSocketServerHandler;
+@Deprecated
public class WebSocketServerInitializer extends ChannelInitializer<SocketChannel> {
@Override
- public void initChannel(SocketChannel ch) throws Exception {
+ public void initChannel(final SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast("codec-http", new HttpServerCodec());
pipeline.addLast("aggregator", new HttpObjectAggregator(65536));
Code Review / yangtools.git / commitdiff