moksha/api/widgets/amqp/amqp.py | 6 ++++--
moksha/templates/amqp_socket.mak | 7 +++++--
2 files changed, 9 insertions(+), 4 deletions(-)
New commits:
commit 342b220751f78235d435804e18cdfb5dec9d5276
Author: Luke Macken <lmacken(a)redhat.com>
Date: Thu May 5 01:04:11 2011 -0400
Declare our live socket AMQP queues as being exclusive
diff --git a/moksha/api/widgets/amqp/amqp.py b/moksha/api/widgets/amqp/amqp.py
index f039757..def4e3b 100644
--- a/moksha/api/widgets/amqp/amqp.py
+++ b/moksha/api/widgets/amqp/amqp.py
@@ -142,11 +142,13 @@ class AMQPSocket(Widget):
moksha_amqp_session.Queue('declare', {
queue: moksha_amqp_remote_queue,
- auto_delete: true
+ auto_delete: true,
+ exclusive: true
});
moksha_amqp_queue = moksha_amqp_session.create_local_queue({
name: 'local_queue',
- auto_delete: true
+ auto_delete: true,
+ exclusive: true
});
% if onconnectedframe:
diff --git a/moksha/templates/amqp_socket.mak b/moksha/templates/amqp_socket.mak
index 4873bce..4cd615d 100644
--- a/moksha/templates/amqp_socket.mak
+++ b/moksha/templates/amqp_socket.mak
@@ -77,10 +77,13 @@ if (typeof moksha_amqp_conn == 'undefined') {
moksha_amqp_session.Queue('declare', {
queue: moksha_amqp_remote_queue,
- auto_delete: true
+ auto_delete: true,
+ exclusive: true
});
moksha_amqp_queue = moksha_amqp_session.create_local_queue({
- name: 'local_queue'
+ name: 'local_queue',
+ auto_delete: true,
+ exclusive: true
});
moksha_amqp_queue.subscribe({
Show replies by date