From 9171f787631ec8d296ea7225e018d659f0703b2c Mon Sep 17 00:00:00 2001 From: Juan Eugenio Abadie Date: Sat, 7 Oct 2017 23:03:49 -0300 Subject: Remove unneeded braces --- examples/amqp_listenq.c | 42 ++++++++++++++++++++---------------------- 1 file changed, 20 insertions(+), 22 deletions(-) (limited to 'examples') diff --git a/examples/amqp_listenq.c b/examples/amqp_listenq.c index 37c06bb..b6439f1 100644 --- a/examples/amqp_listenq.c +++ b/examples/amqp_listenq.c @@ -84,35 +84,33 @@ int main(int argc, char const *const *argv) amqp_basic_consume(conn, 1, amqp_cstring_bytes(queuename), amqp_empty_bytes, 0, 0, 0, amqp_empty_table); die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming"); - { - for (;;) { - amqp_rpc_reply_t res; - amqp_envelope_t envelope; + for (;;) { + amqp_rpc_reply_t res; + amqp_envelope_t envelope; - amqp_maybe_release_buffers(conn); + amqp_maybe_release_buffers(conn); - res = amqp_consume_message(conn, &envelope, NULL, 0); + res = amqp_consume_message(conn, &envelope, NULL, 0); - if (AMQP_RESPONSE_NORMAL != res.reply_type) { - break; - } + if (AMQP_RESPONSE_NORMAL != res.reply_type) { + break; + } - printf("Delivery %u, exchange %.*s routingkey %.*s\n", - (unsigned) envelope.delivery_tag, - (int) envelope.exchange.len, (char *) envelope.exchange.bytes, - (int) envelope.routing_key.len, (char *) envelope.routing_key.bytes); + printf("Delivery %u, exchange %.*s routingkey %.*s\n", + (unsigned) envelope.delivery_tag, + (int) envelope.exchange.len, (char *) envelope.exchange.bytes, + (int) envelope.routing_key.len, (char *) envelope.routing_key.bytes); - if (envelope.message.properties._flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { - printf("Content-type: %.*s\n", - (int) envelope.message.properties.content_type.len, - (char *) envelope.message.properties.content_type.bytes); - } - printf("----\n"); + if (envelope.message.properties._flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { + printf("Content-type: %.*s\n", + (int) envelope.message.properties.content_type.len, + (char *) envelope.message.properties.content_type.bytes); + } + printf("----\n"); - amqp_dump(envelope.message.body.bytes, envelope.message.body.len); + amqp_dump(envelope.message.body.bytes, envelope.message.body.len); - amqp_destroy_envelope(&envelope); - } + amqp_destroy_envelope(&envelope); } die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel"); -- cgit v1.2.1