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 | e5c7264eebe042ee3ab62eb350c43ae8ae137aa7 (patch) | |
| tree | 8d615e56cb54b23c64c305f6b029cef5c0561bbe /qpid/python | |
| parent | f45e21878e4bc92a3e76e5291344099a294afe18 (diff) | |
| download | qpid-python-e5c7264eebe042ee3ab62eb350c43ae8ae137aa7.tar.gz | |
add uuid prefix to addresses beginning with hash(#)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@958083 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python')
| -rw-r--r-- | qpid/python/qpid/messaging/endpoints.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/qpid/python/qpid/messaging/endpoints.py b/qpid/python/qpid/messaging/endpoints.py index 30f51fe955..8bddc96bc8 100644 --- a/qpid/python/qpid/messaging/endpoints.py +++ b/qpid/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: """ |
