Added CLOSED_CHANNEL_ERROR_MESSAGE to fix compilation issues

Author: joviegas

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

@@ -53,6 +53,16 @@ public final class NettyUtils {
      */
     public static final SucceededFuture<?> SUCCEEDED_FUTURE = new SucceededFuture<>(null, null);
 
+    public static final String CLOSED_CHANNEL_ERROR_MESSAGE = "The connection was closed during the request. The request will "
+                                                              + "usually succeed on a "
+                                                              + "retry, but if it does"
+                                                              + " not: consider disabling any proxies you have configured, "
+                                                              + "enabling debug logging, or "
+                                                              + "performing a TCP"
+                                                              + " dump to identify the root cause. If this is a streaming "
+                                                              + "operation, validate that data"
+                                                              + " is being read or"
+                                                              + " written in a timely manner.";
     private static final Logger log = Logger.loggerFor(NettyUtils.class);
 
     private NettyUtils() {
@@ -140,10 +150,7 @@ public static String closedChannelMessage(Channel channel) {
                                                       channel.parent().attr(CHANNEL_DIAGNOSTICS).get() : null;
 
         StringBuilder error = new StringBuilder();
-        error.append("The connection was closed during the request. The request will usually succeed on a retry, but if it does"
-                     + " not: consider disabling any proxies you have configured, enabling debug logging, or performing a TCP"
-                     + " dump to identify the root cause. If this is a streaming operation, validate that data is being read or"
-                     + " written in a timely manner.");
+        error.append(CLOSED_CHANNEL_ERROR_MESSAGE);
 
         if (channelDiagnostics != null) {
             error.append(" Channel Information: ").append(channelDiagnostics);

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

@@ -29,6 +29,7 @@
 import io.netty.handler.ssl.SslContext;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.SslHandler;
+import io.netty.util.Attribute;
 import io.netty.util.AttributeKey;
 import io.netty.util.concurrent.EventExecutor;
 import io.netty.util.concurrent.Future;
@@ -41,6 +42,7 @@
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
 import org.slf4j.Logger;
 import software.amazon.awssdk.http.nio.netty.internal.MockChannel;
 
@@ -222,7 +224,7 @@ public void runAndLogError_runnableThrows_loggerInvoked() {
 
         verify(delegateLogger).error(msg, error);
     }
-    
+
     @Test
     public void closedChannelMessage_with_nullChannelAttribute() throws Exception {
 
@@ -244,24 +246,24 @@ public void closedChannelMessage_with_nullChannel() throws Exception {
     @Test
     public void closedChannelMessage_with_nullParentChannel() throws Exception {
 
-        Channel channel = Mockito.mock(Channel.class);
-        Attribute attribute = Mockito.mock(Attribute.class);
+        Channel channel = mock(Channel.class);
+        Attribute attribute = mock(Attribute.class);
         when(channel.parent()).thenReturn(null);
-        when(channel.attr(Mockito.any())).thenReturn(attribute);
+        when(channel.attr(any())).thenReturn(attribute);
 
         assertThat(NettyUtils.closedChannelMessage(channel))
             .isEqualTo(NettyUtils.CLOSED_CHANNEL_ERROR_MESSAGE);
     }
-    
+
     @Test
     public void closedChannelMessage_with_nullParentChannelAttribute() throws Exception {
 
-        Channel channel = Mockito.mock(Channel.class);
-        Attribute attribute = Mockito.mock(Attribute.class);
-        Channel parentChannel = Mockito.mock(Channel.class);
+        Channel channel = mock(Channel.class);
+        Attribute attribute = mock(Attribute.class);
+        Channel parentChannel = mock(Channel.class);
         when(channel.parent()).thenReturn(parentChannel);
-        when(channel.attr(Mockito.any())).thenReturn(attribute);
-        when(parentChannel.attr(Mockito.any())).thenReturn(null);
+        when(channel.attr(any())).thenReturn(attribute);
+        when(parentChannel.attr(any())).thenReturn(null);
 
         assertThat(NettyUtils.closedChannelMessage(channel))
             .isEqualTo(NettyUtils.CLOSED_CHANNEL_ERROR_MESSAGE);