From 7a3e2ae5fcd83bcbd46563485029334814199748 Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Fri, 25 Jun 2010 19:06:05 +0000
Subject: 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
---
 python/qpid/messaging/endpoints.py | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'python')

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:
 
   """
-- 
cgit v1.2.1