Additional log messages

Author: ValentinZakharov

dd-java-agent/instrumentation/netty-4.1/src/test/groovy/Netty41ServerTest.groovy

@@ -78,6 +78,7 @@ abstract class Netty41ServerTest extends HttpServerTest<EventLoopGroup> {
             pipeline.addLast(new WebSocketServerProtocolHandler("/websocket"))
             pipeline.addLast([
               channelRead0       : { ChannelHandlerContext ctx, msg ->
+                System.out.println(">> onRead: ${msg}")
                 if (msg instanceof HttpRequest) {
                   def request = msg as HttpRequest
                   if (is100ContinueExpected(request)) {
@@ -177,10 +178,12 @@ abstract class Netty41ServerTest extends HttpServerTest<EventLoopGroup> {
               userEventTriggered : { ChannelHandlerContext ctx, Object evt ->
                 System.out.println("Received event $evt. session is ${WsEndpoint.activeSession}")
                 if (evt instanceof WebSocketServerProtocolHandler.HandshakeComplete) {
+                  System.out.println(">> onOpen")
                   WsEndpoint.onOpen(ctx)
                 }
               },
               channelInactive    : { ChannelHandlerContext ctx ->
+                System.out.println(">> onClose")
                 WsEndpoint.onClose()
               }
             ] as SimpleChannelInboundHandler)
@@ -211,6 +214,7 @@ abstract class Netty41ServerTest extends HttpServerTest<EventLoopGroup> {
 
     @Override
     void serverSendText(String[] messages) {
+      System.out.println(">> serverSendText: ${messages.length} messages")
       WsEndpoint.activeSession.writeAndFlush(new TextWebSocketFrame(messages.length == 1, 0, messages[0]))
       for (def i = 1; i < messages.length; i++) {
         WsEndpoint.activeSession.writeAndFlush(new ContinuationWebSocketFrame(messages.length - 1 == i, 0, messages[i]))
@@ -219,6 +223,7 @@ abstract class Netty41ServerTest extends HttpServerTest<EventLoopGroup> {
 
     @Override
     void serverSendBinary(byte[][] binaries) {
+      System.out.println(">> serverSendBinary: ${binaries.length} messages")
       WsEndpoint.activeSession.writeAndFlush(new BinaryWebSocketFrame(binaries.length == 1, 0, Unpooled.wrappedBuffer(binaries[0])))
       for (def i = 1; i < binaries.length; i++) {
         WsEndpoint.activeSession.writeAndFlush(new ContinuationWebSocketFrame(binaries.length - 1 == i, 0, Unpooled.wrappedBuffer(binaries[i])))
@@ -227,6 +232,7 @@ abstract class Netty41ServerTest extends HttpServerTest<EventLoopGroup> {
 
     @Override
     void serverClose() {
+      System.out.println(">> serverClose")
       WsEndpoint.activeSession.writeAndFlush(new CloseWebSocketFrame(1000, null)).addListener(ChannelFutureListener.CLOSE)
     }