uWSGI requests a transient queue but does not set the `auto-delete` bit resulting in unbounded creation of new -> abandonded queues.
Signed-off-by: C Anthony Risinger <[email protected]> --- 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 0940da2..3c1efd0 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); -- 1.7.11.3 _______________________________________________ uWSGI mailing list [email protected] http://lists.unbit.it/cgi-bin/mailman/listinfo/uwsgi
