diff options
| author | Ted Ross <tross@apache.org> | 2009-02-19 12:00:46 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2009-02-19 12:00:46 +0000 |
| commit | c1095c7c31360307e66b1a7d549775c34dba92fd (patch) | |
| tree | 5667d39a6b6995860d3c1e2c9fdb1a747dcd872e /qpid/python/qmf | |
| parent | d829b858fe0242caa9cf430b108c619360058262 (diff) | |
| download | qpid-python-c1095c7c31360307e66b1a7d549775c34dba92fd.tar.gz | |
QPID-1669 - Added client connection management to qpid-cluster.
Also added better session-id discrimination in the qmf.console library.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@745832 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/qmf')
| -rw-r--r-- | qpid/python/qmf/console.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/python/qmf/console.py b/qpid/python/qmf/console.py index 867d707f31..abc0929955 100644 --- a/qpid/python/qmf/console.py +++ b/qpid/python/qmf/console.py @@ -1230,6 +1230,7 @@ class ManagedConnection(Thread): class Broker: """ This object represents a connection (or potential connection) to a QMF broker. """ SYNC_TIME = 60 + nextSeq = 1 def __init__(self, session, host, port, authMech, authUser, authPass, ssl=False): self.session = session @@ -1242,7 +1243,8 @@ class Broker: self.error = None self.brokerId = None self.connected = False - self.amqpSessionId = "%s.%d" % (os.uname()[1], os.getpid()) + self.amqpSessionId = "%s.%d.%d" % (os.uname()[1], os.getpid(), Broker.nextSeq) + Broker.nextSeq += 1 if self.session.manageConnections: self.thread = ManagedConnection(self) self.thread.start() |