From: Robert Varga Date: Wed, 2 Jul 2014 20:32:07 +0000 (+0200) Subject: BUG-868: donot use deprecated call X-Git-Tag: release/helium~551 X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=commitdiff_plain;h=706ed92f6f28d0151a4e4b06f503f31135960ec4 BUG-868: donot use deprecated call WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse() is the replacement, so use it instead of sendUnsupportedWebSocketVersionResponse(). Change-Id: I03116f09e757df9694ac077c9e82296eaf19de90 Signed-off-by: Robert Varga --- diff --git a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServerHandler.java b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServerHandler.java index b5d6a6ea9b..26e4936d3f 100644 --- a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServerHandler.java +++ b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/streams/websockets/WebSocketServerHandler.java @@ -46,7 +46,7 @@ public class WebSocketServerHandler extends SimpleChannelInboundHandler private WebSocketServerHandshaker handshaker; @Override - protected void channelRead0(ChannelHandlerContext ctx, Object msg) + protected void channelRead0(final ChannelHandlerContext ctx, final Object msg) throws Exception { if (msg instanceof FullHttpRequest) { handleHttpRequest(ctx, (FullHttpRequest) msg); @@ -64,8 +64,8 @@ public class WebSocketServerHandler extends SimpleChannelInboundHandler * @param req * FullHttpRequest */ - 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, @@ -97,8 +97,7 @@ public class WebSocketServerHandler extends SimpleChannelInboundHandler getWebSocketLocation(req), null, false); handshaker = wsFactory.newHandshaker(req); if (handshaker == null) { - WebSocketServerHandshakerFactory - .sendUnsupportedWebSocketVersionResponse(ctx.channel()); + WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(ctx.channel()); } else { handshaker.handshake(ctx.channel(), req); } @@ -115,8 +114,8 @@ public class WebSocketServerHandler extends SimpleChannelInboundHandler * @param res * FullHttpResponse */ - private static void sendHttpResponse(ChannelHandlerContext ctx, - HttpRequest req, FullHttpResponse res) { + private static void sendHttpResponse(final ChannelHandlerContext ctx, + final HttpRequest 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(), @@ -141,8 +140,8 @@ public class WebSocketServerHandler extends SimpleChannelInboundHandler * @param frame * {@link WebSocketFrame} */ - private void handleWebSocketFrame(ChannelHandlerContext ctx, - WebSocketFrame frame) throws IOException { + private void handleWebSocketFrame(final ChannelHandlerContext ctx, + final WebSocketFrame frame) throws IOException { if (frame instanceof CloseWebSocketFrame) { handshaker.close(ctx.channel(), (CloseWebSocketFrame) frame.retain()); @@ -164,7 +163,7 @@ public class WebSocketServerHandler extends SimpleChannelInboundHandler } @Override - public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) + public void exceptionCaught(final ChannelHandlerContext ctx, final Throwable cause) throws Exception { if (cause instanceof java.nio.channels.ClosedChannelException == false) { // cause.printStackTrace(); @@ -179,7 +178,7 @@ public class WebSocketServerHandler extends SimpleChannelInboundHandler * HTTP request from which the location will be returned * @return String representation of web socket location. */ - private static String getWebSocketLocation(HttpRequest req) { + private static String getWebSocketLocation(final HttpRequest req) { return "http://" + req.headers().get(HOST) + req.getUri(); }