diff --git a/oslo_messaging/_drivers/amqp1_driver/eventloop.py b/oslo_messaging/_drivers/amqp1_driver/eventloop.py
index c2e16fbe0..34added77 100644
--- a/oslo_messaging/_drivers/amqp1_driver/eventloop.py
+++ b/oslo_messaging/_drivers/amqp1_driver/eventloop.py
@@ -93,8 +93,8 @@ class _SocketConnection(object):
 
     def connect(self, host):
         """Connect to host and start the AMQP protocol."""
-        addr = socket.getaddrinfo(host.hostname, host.port,
-                                  socket.AF_INET, socket.SOCK_STREAM)
+        addr = socket.getaddrinfo(host.hostname, host.port, socket.AF_UNSPEC,
+                                  socket.SOCK_STREAM)
         if not addr:
             key = "%s:%i" % (host.hostname, host.port)
             error = "Invalid peer address '%s'" % key