Set address resolver in test

The default address resolver uses 2 inet addresses, which can trigger a
retry if the first connection attempt fails. The test is meant to fail
with a ProtocolVersionMismatch exception, retrying is not necessary and
makes debugging harder.

(cherry picked from commit bb26af7)

Author: acogoluegnes

src/test/java/com/rabbitmq/client/test/ProtocolVersionMismatch.java

@@ -17,7 +17,10 @@
 
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
+import com.rabbitmq.client.Address;
+import com.rabbitmq.client.AddressResolver;
 import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.ListAddressResolver;
 import com.rabbitmq.client.MalformedFrameException;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.buffer.ByteBuf;
@@ -31,12 +34,17 @@
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 import io.netty.util.ReferenceCountUtil;
+import java.util.Collections;
 import java.util.concurrent.TimeUnit;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class ProtocolVersionMismatch {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(ProtocolVersionMismatch.class);
+
   @ParameterizedTest
   @MethodSource("com.rabbitmq.client.test.TestUtils#ioLayers")
   void connectionShouldFailWithProtocolVersionMismatch(String ioLayer) throws Exception {
@@ -45,7 +53,10 @@ void connectionShouldFailWithProtocolVersionMismatch(String ioLayer) throws Exce
       ConnectionFactory cf = TestUtils.connectionFactory();
       TestUtils.setIoLayer(cf, ioLayer);
       cf.setPort(port);
-      assertThatThrownBy(cf::newConnection).hasRootCauseInstanceOf(MalformedFrameException.class);
+      AddressResolver addressResolver =
+          new ListAddressResolver(Collections.singletonList(new Address("localhost", port)));
+      assertThatThrownBy(() -> cf.newConnection(addressResolver))
+          .hasRootCauseInstanceOf(MalformedFrameException.class);
     }
   }
 
@@ -69,6 +80,7 @@ protected void initChannel(SocketChannel ch) {
                           new ChannelInboundHandlerAdapter() {
                             @Override
                             public void channelRead(ChannelHandlerContext ctx, Object msg) {
+                              LOGGER.debug("Client connection in test AMQP 1.0 server");
                               // discard the data
                               ReferenceCountUtil.release(msg);
                               ByteBuf b = ctx.alloc().buffer(AMQP_HEADER.length);

src/test/java/com/rabbitmq/client/test/TestUtils.java

@@ -40,7 +40,6 @@
 import java.util.concurrent.TimeoutException;
 import java.util.function.Function;
 import java.util.function.Supplier;
-
 import org.assertj.core.api.Assertions;
 import org.assertj.core.api.Condition;
 import org.junit.jupiter.api.extension.ConditionEvaluationResult;
@@ -135,7 +134,8 @@ public static void waitAtMost(Duration timeout, CallableBooleanSupplier conditio
     waitAtMost(timeout, condition, null);
   }
 
-  public static void waitAtMost(Duration timeout, CallableBooleanSupplier condition, Supplier<String> message) {
+  public static void waitAtMost(
+      Duration timeout, CallableBooleanSupplier condition, Supplier<String> message) {
     try {
       if (condition.getAsBoolean()) {
         return;

src/test/resources/logback-test.xml

@@ -9,6 +9,7 @@
     <logger name="com.rabbitmq.client.test.server.TopicPermissions" level="debug" />
     <logger name="com.rabbitmq.client.impl.AbstractMetricsCollector" level="debug" />
     <logger name="com.rabbitmq.client.impl.NettyFrameHandlerFactory" level="debug" />
+    <logger name="com.rabbitmq.client.test.ProtocolVersionMismatch" level="debug" />
 
     <root level="warn">
         <appender-ref ref="STDOUT" />