PushConnection close method (#1995)

Exposes a close method in the event that action needs to be triggered
from a different channelHandlerContext that has the instance of the
pushConnection

Author: tappenzeller

zuul-core/src/main/java/com/netflix/zuul/netty/server/push/PushConnection.java

@@ -21,7 +21,10 @@
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
+import io.netty.handler.codec.http.websocketx.WebSocketCloseStatus;
 
 /**
  * Author: Susheel Aroskar
@@ -92,4 +95,9 @@ public ChannelFuture sendPushMessage(String mesg) {
     public ChannelFuture sendPing() {
         return pushProtocol.sendPing(ctx);
     }
+
+    public void closeConnection(WebSocketCloseStatus status, String message) {
+        ctx.writeAndFlush(new CloseWebSocketFrame(status, message))
+                .addListener(ChannelFutureListener.CLOSE);
+    }
 }