Class DnsRecordIpAddressResolver

  • All Implemented Interfaces:
    AddressResolver

    public class DnsRecordIpAddressResolver
    extends java.lang.Object
    implements AddressResolver
    AddressResolver that resolves DNS record IPs. Uses InetAddress internally. The first returned address is used when automatic recovery is NOT enabled at the ConnectionFactory level. When automatic recovery is enabled, a random address will be picked up from the returned list of Addresses.
    • Field Detail

      • address

        private final Address address
      • ssl

        private final boolean ssl
    • Constructor Detail

      • DnsRecordIpAddressResolver

        public DnsRecordIpAddressResolver​(java.lang.String hostname,
                                          int port,
                                          boolean ssl)
      • DnsRecordIpAddressResolver

        public DnsRecordIpAddressResolver​(java.lang.String hostname,
                                          int port)
      • DnsRecordIpAddressResolver

        public DnsRecordIpAddressResolver()
      • DnsRecordIpAddressResolver

        public DnsRecordIpAddressResolver​(java.lang.String hostname)
      • DnsRecordIpAddressResolver

        public DnsRecordIpAddressResolver​(Address address)
      • DnsRecordIpAddressResolver

        public DnsRecordIpAddressResolver​(Address address,
                                          boolean ssl)
    • Method Detail

      • getAddresses

        public java.util.List<Address> getAddresses()
                                             throws java.net.UnknownHostException
        Get the IP addresses from a DNS query
        Specified by:
        getAddresses in interface AddressResolver
        Returns:
        candidate Addresses
        Throws:
        java.io.IOException - if DNS resolution fails
        java.net.UnknownHostException
      • resolveIpAddresses

        protected java.net.InetAddress[] resolveIpAddresses​(java.lang.String hostName)
                                                     throws java.net.UnknownHostException
        Throws:
        java.net.UnknownHostException