Make SslCloseCompletionEventHandler sharable

Author: dagnir

http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ChannelPipelineInitializer.java

@@ -65,7 +65,7 @@ public void channelCreated(Channel ch) {
         ChannelPipeline pipeline = ch.pipeline();
         if (sslCtx != null) {
             pipeline.addLast(sslCtx.newHandler(ch.alloc()));
-            pipeline.addLast(new SslCloseCompletionEventHandler());
+            pipeline.addLast(SslCloseCompletionEventHandler.getInstance());
         }
 
         if (protocol == Protocol.HTTP2) {

http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/SslCloseCompletionEventHandler.java

@@ -15,6 +15,7 @@
 
 package software.amazon.awssdk.http.nio.netty.internal;
 
+import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.handler.ssl.SslCloseCompletionEvent;
@@ -26,8 +27,14 @@
  * in this state can't be reused so they must be closed.
  */
 @SdkInternalApi
+@ChannelHandler.Sharable
 public final class SslCloseCompletionEventHandler extends ChannelInboundHandlerAdapter {
 
+    private static final SslCloseCompletionEventHandler INSTANCE = new SslCloseCompletionEventHandler();
+
+    private SslCloseCompletionEventHandler() {
+    }
+
     @Override
     public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
         if (evt instanceof SslCloseCompletionEvent) {
@@ -36,4 +43,8 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
             ctx.fireUserEventTriggered(evt);
         }
     }
+
+    public static SslCloseCompletionEventHandler getInstance() {
+        return INSTANCE;
+    }
 }

http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/SslCloseCompletionEventHandlerTest.java

@@ -35,15 +35,15 @@ public void setup() {
 
     @Test
     public void userEventTriggered_ClosesChannel() {
-        SslCloseCompletionEventHandler handler = new SslCloseCompletionEventHandler();
+        SslCloseCompletionEventHandler handler = SslCloseCompletionEventHandler.getInstance();
         handler.userEventTriggered(ctx, new SslCloseCompletionEvent(new ClosedChannelException()));
 
         verify(ctx).close();
     }
 
     @Test
     public void userEventTriggered_StaticVariable_ClosesChannel() {
-        SslCloseCompletionEventHandler handler = new SslCloseCompletionEventHandler();
+        SslCloseCompletionEventHandler handler = SslCloseCompletionEventHandler.getInstance();
         handler.userEventTriggered(ctx, SslCloseCompletionEvent.SUCCESS);
 
         verify(ctx).close();