diff options
Diffstat (limited to 'tools/get.c')
| -rw-r--r-- | tools/get.c | 55 |
1 files changed, 29 insertions, 26 deletions
diff --git a/tools/get.c b/tools/get.c index 888e069..bbcde72 100644 --- a/tools/get.c +++ b/tools/get.c @@ -41,40 +41,43 @@ static int do_get(amqp_connection_state_t conn, char *queue) { - amqp_rpc_reply_t r - = amqp_basic_get(conn, 1, cstring_bytes(queue), 1); - die_rpc(r, "basic.get"); + amqp_rpc_reply_t r + = amqp_basic_get(conn, 1, cstring_bytes(queue), 1); + die_rpc(r, "basic.get"); - if (r.reply.id == AMQP_BASIC_GET_EMPTY_METHOD) - return 0; + if (r.reply.id == AMQP_BASIC_GET_EMPTY_METHOD) { + return 0; + } - copy_body(conn, 1); - return 1; + copy_body(conn, 1); + return 1; } int main(int argc, const char **argv) { - amqp_connection_state_t conn; - char *queue = NULL; - int got_something; + amqp_connection_state_t conn; + char *queue = NULL; + int got_something; - struct poptOption options[] = { - INCLUDE_OPTIONS(connect_options), - {"queue", 'q', POPT_ARG_STRING, &queue, 0, - "the queue to consume from", "queue"}, - POPT_AUTOHELP - { NULL, '\0', 0, NULL, 0, NULL, NULL } - }; + struct poptOption options[] = { + INCLUDE_OPTIONS(connect_options), + { + "queue", 'q', POPT_ARG_STRING, &queue, 0, + "the queue to consume from", "queue" + }, + POPT_AUTOHELP + { NULL, '\0', 0, NULL, 0, NULL, NULL } + }; - process_all_options(argc, argv, options); + process_all_options(argc, argv, options); - if (!queue) { - fprintf(stderr, "queue not specified\n"); - return 1; - } + if (!queue) { + fprintf(stderr, "queue not specified\n"); + return 1; + } - conn = make_connection(); - got_something = do_get(conn, queue); - close_connection(conn); - return got_something ? 0 : 2; + conn = make_connection(); + got_something = do_get(conn, queue); + close_connection(conn); + return got_something ? 0 : 2; } |