Enable DNS round robin with TLS hostname verification

(cherry picked from commit 58e14f8)

Conflicts:
	src/main/java/com/rabbitmq/client/ConnectionFactory.java

Author: ogolberg

src/main/java/com/rabbitmq/client/Address.java

@@ -16,6 +16,7 @@
 
 package com.rabbitmq.client;
 
+import java.net.InetSocketAddress;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -161,6 +162,13 @@ public static Address parseAddress(String addressString) {
         }
     }
 
+    /**
+     * Construct an InetSocketAddress for this address with a specific port
+     */
+    public InetSocketAddress toInetSocketAddress(int port) {
+        return new InetSocketAddress(getHost(), port);
+    }
+
     /**
      * Array-based factory method: takes an array of formatted address strings as construction parameter
      * @param addresses array of strings of form "host[:port],..."
@@ -191,5 +199,4 @@ public static Address[] parseAddresses(String addresses) {
     @Override public String toString() {
         return _port == -1 ? _host : _host + ":" + _port;
     }
-
 }

src/main/java/com/rabbitmq/client/ConnectionFactory.java

@@ -1343,10 +1343,10 @@ public Connection newConnection(ExecutorService executor, String connectionName)
     }
 
     protected AddressResolver createAddressResolver(List<Address> addresses) {
-        if(addresses.size() == 1 && !isSSL()) {
-            return new DnsRecordIpAddressResolver(addresses.get(0), isSSL());
-        } else {
+        if (addresses.size() > 1) {
             return new ListAddressResolver(addresses);
+        } else {
+            return new DnsRecordIpAddressResolver(addresses.get(0), isSSL());
         }
     }
 

src/main/java/com/rabbitmq/client/DnsRecordIpAddressResolver.java

@@ -72,9 +72,9 @@ public List<Address> getAddresses() throws UnknownHostException {
 
         InetAddress[] inetAddresses = resolveIpAddresses(hostName);
 
-        List<Address> addresses = new ArrayList<Address>();
+        List<Address> addresses = new ArrayList<>();
         for (InetAddress inetAddress : inetAddresses) {
-            addresses.add(new Address(inetAddress.getHostAddress(), portNumber));
+            addresses.add(new ResolvedInetAddress(inetAddress, portNumber));
         }
         return addresses;
     }

src/main/java/com/rabbitmq/client/ResolvedInetAddress.java

@@ -0,0 +1,23 @@
+package com.rabbitmq.client;
+
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+
+public class ResolvedInetAddress extends Address {
+    private final InetAddress inetAddress;
+
+    public ResolvedInetAddress(InetAddress inetAddress, int port) {
+        super(inetAddress.getHostAddress(), port);
+        this.inetAddress = inetAddress;
+    }
+
+    public ResolvedInetAddress(InetAddress inetAddress) {
+        super(inetAddress.getHostAddress());
+        this.inetAddress = inetAddress;
+    }
+
+    @Override
+    public InetSocketAddress toInetSocketAddress(int port) {
+        return new InetSocketAddress(inetAddress, port);
+    }
+}

src/main/java/com/rabbitmq/client/impl/SocketFrameHandlerFactory.java

@@ -17,6 +17,7 @@
 
 import com.rabbitmq.client.Address;
 import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.ResolvedInetAddress;
 import com.rabbitmq.client.SocketConfigurator;
 import com.rabbitmq.client.SslContextFactory;
 
@@ -51,14 +52,13 @@ public SocketFrameHandlerFactory(int connectionTimeout, SocketFactory socketFact
     }
 
     public FrameHandler create(Address addr, String connectionName) throws IOException {
-        String hostName = addr.getHost();
         int portNumber = ConnectionFactory.portOrDefault(addr.getPort(), ssl);
         Socket socket = null;
         try {
             socket = createSocket(connectionName);
             configurator.configure(socket);
-            socket.connect(new InetSocketAddress(hostName, portNumber),
-                    connectionTimeout);
+
+            socket.connect(addr.toInetSocketAddress(portNumber), connectionTimeout);
             return create(socket);
         } catch (IOException ioe) {
             quietTrySocketClose(socket);

src/main/java/com/rabbitmq/client/impl/nio/SocketChannelFrameHandlerFactory.java

@@ -85,7 +85,7 @@ public FrameHandler create(Address addr, String connectionName) throws IOExcepti
                 }
             }
 
-            SocketAddress address = new InetSocketAddress(addr.getHost(), portNumber);
+            SocketAddress address = addr.toInetSocketAddress(portNumber);
             // No Sonar: the channel is closed in case of error and it cannot
             // be closed here because it's part of the state of the connection
             // to be returned.