[QPID-5823]: Python client should create a node with name starting '\#'
diff --git a/qpid/messaging/driver.py b/qpid/messaging/driver.py
index e8ab964..6f1d0fb 100644
--- a/qpid/messaging/driver.py
+++ b/qpid/messaging/driver.py
@@ -29,6 +29,7 @@
from qpid.messaging.constants import UNLIMITED, REJECTED, RELEASED
from qpid.messaging.exceptions import *
from qpid.messaging.message import get_codec, Disposition, Message
+from qpid.messaging.endpoints import MangledString
from qpid.ops import *
from qpid.selector import Selector
from qpid.util import URL, default,get_client_properties_with_defaults
@@ -945,6 +946,14 @@
# XXX: subject
if lnk.options is None:
lnk.options = {}
+ if isinstance(addr, MangledString):
+ lnk.options['create'] = "always"
+ if 'node' not in lnk.options:
+ lnk.options['node'] = {}
+ if 'x-declare' not in lnk.options['node']:
+ lnk.options['node']['x-declare'] = {}
+ lnk.options['node']['x-declare']['auto-delete'] = "True"
+ lnk.options['node']['x-declare']['exclusive'] = "True"
except address.LexError, e:
return MalformedAddress(text=str(e))
except address.ParseError, e:
diff --git a/qpid/messaging/endpoints.py b/qpid/messaging/endpoints.py
index eb4c196..5b10fbd 100644
--- a/qpid/messaging/endpoints.py
+++ b/qpid/messaging/endpoints.py
@@ -778,9 +778,11 @@
finally:
self.connection._remove_session(self)
+class MangledString(str): pass
+
def _mangle(addr):
if addr and addr.startswith("#"):
- return str(uuid4()) + addr
+ return MangledString(str(uuid4()) + addr)
else:
return addr
