From 44e773f7379758ccb86d4561edaa8db390034341 Mon Sep 17 00:00:00 2001 From: C Anthony Risinger Date: Wed, 25 Jul 2012 12:19:35 -0500 Subject: [PATCH] AMQP Emperor: Auto-delete transient queues uWSGI requests a transient queue but does not set the `auto-delete` bit resulting in unbounded creation of new -> abandonded queues. --- plugins/emperor_amqp/amqp.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/plugins/emperor_amqp/amqp.c b/plugins/emperor_amqp/amqp.c index 0940da2e..3c1efd06 100644 --- a/plugins/emperor_amqp/amqp.c +++ b/plugins/emperor_amqp/amqp.c @@ -610,8 +610,8 @@ static int amqp_send_queue_declare(int fd, char *queue) { amqp_send(fd, &shortsize, 1); amqp_send(fd, queue, shortsize); - // empty bits - amqp_send(fd, "\0", 1); + // set auto-delete bit + amqp_send(fd, "\x08", 1); // empty table amqp_send(fd, "\0\0\0\0", 4);