Merge pull request #10 from xtfxme/defect-emperor-amqp-transient-queues

AMQP Emperor: Auto-delete transient queues
This commit is contained in:
unbit
2012-07-26 22:12:55 -07:00
+2 -2
View File
@@ -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);