Better sysname prepend to queue name, fixes OOIION-699

ooici · Feb 12, 2013 · fec1e38 · fec1e38
1 parent 6e94a42
commit fec1e38
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pyon/net/channel.py b/pyon/net/channel.py
@@ -672,7 +672,7 @@ def close_impl(self):
     def _declare_queue(self, queue):
 
         # prepend xp name in the queue for anti-clobbering
-        if queue and not self._recv_name.exchange in queue:
+        if queue and not queue.startswith(self._recv_name.exchange + "."):
             queue = ".".join([self._recv_name.exchange, queue])
             #log.debug('Auto-prepending exchange to queue name for anti-clobbering: %s', queue)