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@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({