From a3b5ba5a04c7227dc53043f18665904ea8af6d3c Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Wed, 14 Jul 2010 19:47:37 +0000 Subject: default ports for reconnect_urls git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964151 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/messaging/driver.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'python/qpid/messaging/driver.py') 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] -- cgit v1.2.1