diff options
| author | Andrew Smith <ansmith@redhat.com> | 2017-01-18 12:09:24 -0500 |
|---|---|---|
| committer | Kenneth Giusti <kgiusti@gmail.com> | 2017-01-30 09:54:03 -0500 |
| commit | 28d5df8d2e91f906403bf577456b46d2c4d6a5a4 (patch) | |
| tree | 0e37223ae36f2832f130becd35b945b0b6726b6b | |
| parent | 96e23ebd1184c4809d4ad9c0b1da716eb056cd88 (diff) | |
| download | oslo-messaging-5.17.1.tar.gz | |
Return list of addresses for IPV4 and IPV65.17.1
Closes-Bug: 1657485
Change-Id: Ifd0c338442b97b2ad9476e2856af120d7080f025
(cherry picked from commit 58f20a8812b3067dbc7226922015b46de75461c7)
| -rw-r--r-- | oslo_messaging/_drivers/amqp1_driver/eventloop.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/oslo_messaging/_drivers/amqp1_driver/eventloop.py b/oslo_messaging/_drivers/amqp1_driver/eventloop.py index c2e16fb..34added 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 |