diff options
Diffstat (limited to 'python/qpid/messaging/driver.py')
| -rw-r--r-- | python/qpid/messaging/driver.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/python/qpid/messaging/driver.py b/python/qpid/messaging/driver.py index 1e1055a723..9b34a46e19 100644 --- a/python/qpid/messaging/driver.py +++ b/python/qpid/messaging/driver.py @@ -31,7 +31,7 @@ from qpid.messaging.exceptions import * from qpid.messaging.message import get_codec, Disposition, Message from qpid.ops import * from qpid.selector import Selector -from qpid.util import URL +from qpid.util import URL, default from qpid.validator import And, Context, List, Map, Types, Values from threading import Condition, Thread @@ -347,8 +347,8 @@ class Driver: def _next_host(self): urls = [URL(u) for u in self.connection.reconnect_urls] - hosts = [(self.connection.host, self.connection.port)] + \ - [(u.host, u.port) for u in urls] + hosts = [(self.connection.host, default(self.connection.port, 5672))] + \ + [(u.host, default(u.port, 5672)) for u in urls] if self._host >= len(hosts): self._host = 0 result = hosts[self._host] |