diff options
author | Rafael H. Schloming <rhs@apache.org> | 2010-06-25 19:06:05 +0000 |
---|---|---|
committer | Rafael H. Schloming <rhs@apache.org> | 2010-06-25 19:06:05 +0000 |
commit | 7a3e2ae5fcd83bcbd46563485029334814199748 (patch) | |
tree | db46903e88731e0c63fb9c4946f9d4bd4532825f /python/qpid/messaging/endpoints.py | |
parent | 91dac8d15ccca911bcdab1079637afbe6f4fa504 (diff) | |
download | qpid-python-7a3e2ae5fcd83bcbd46563485029334814199748.tar.gz |
add uuid prefix to addresses beginning with hash(#)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@958083 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/messaging/endpoints.py')
-rw-r--r-- | python/qpid/messaging/endpoints.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/python/qpid/messaging/endpoints.py b/python/qpid/messaging/endpoints.py index 30f51fe955..8bddc96bc8 100644 --- a/python/qpid/messaging/endpoints.py +++ b/python/qpid/messaging/endpoints.py @@ -543,6 +543,7 @@ class Session: @rtype: Sender @return: a new Sender for the specified target """ + target = _mangle(target) sender = Sender(self, self.next_sender_id, target, options) self.next_sender_id += 1 self.senders.append(sender) @@ -566,6 +567,7 @@ class Session: @rtype: Receiver @return: a new Receiver for the specified source """ + source = _mangle(source) receiver = Receiver(self, self.next_receiver_id, source, options) self.next_receiver_id += 1 self.receivers.append(receiver) @@ -707,6 +709,12 @@ class Session: finally: self.connection._remove_session(self) +def _mangle(addr): + if addr.startswith("#"): + return str(uuid4()) + addr + else: + return addr + class Sender: """ |