summaryrefslogtreecommitdiff
path: root/examples/amqp_rpc_sendstring_client.c
diff options
context:
space:
mode:
authorAlan Antonuk <alan.antonuk@gmail.com>2013-04-08 14:52:53 -0700
committerAlan Antonuk <alan.antonuk@gmail.com>2013-04-08 14:52:53 -0700
commitad2b116059e22d393b7e44ad54f345a3fb4e267b (patch)
treecfd98876757f85d9fe7bfe56d179bd5fb63a8ff0 /examples/amqp_rpc_sendstring_client.c
parentf3074030723b840690458983b63c746549aa3bd5 (diff)
downloadrabbitmq-c-github-ask-ad2b116059e22d393b7e44ad54f345a3fb4e267b.tar.gz
Formatted source code with astyle utilty
Diffstat (limited to 'examples/amqp_rpc_sendstring_client.c')
-rw-r--r--examples/amqp_rpc_sendstring_client.c18
1 files changed, 12 insertions, 6 deletions
diff --git a/examples/amqp_rpc_sendstring_client.c b/examples/amqp_rpc_sendstring_client.c
index 04c073e..7914e2c 100644
--- a/examples/amqp_rpc_sendstring_client.c
+++ b/examples/amqp_rpc_sendstring_client.c
@@ -43,7 +43,8 @@
#include "utils.h"
-int main(int argc, char* argv[]) {
+int main(int argc, char *argv[])
+{
char const *hostname;
int port;
char const *exchange;
@@ -152,16 +153,19 @@ int main(int argc, char* argv[]) {
amqp_maybe_release_buffers(conn);
result = amqp_simple_wait_frame(conn, &frame);
printf("Result: %d\n", result);
- if (result < 0)
+ if (result < 0) {
break;
+ }
printf("Frame type: %d channel: %d\n", frame.frame_type, frame.channel);
- if (frame.frame_type != AMQP_FRAME_METHOD)
+ if (frame.frame_type != AMQP_FRAME_METHOD) {
continue;
+ }
printf("Method: %s\n", amqp_method_name(frame.payload.method.id));
- if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD)
+ if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD) {
continue;
+ }
d = (amqp_basic_deliver_t *) frame.payload.method.decoded;
printf("Delivery: %u exchange: %.*s routingkey: %.*s\n",
@@ -170,8 +174,9 @@ int main(int argc, char* argv[]) {
(int) d->routing_key.len, (char *) d->routing_key.bytes);
result = amqp_simple_wait_frame(conn, &frame);
- if (result < 0)
+ if (result < 0) {
break;
+ }
if (frame.frame_type != AMQP_FRAME_HEADER) {
fprintf(stderr, "Expected header!");
@@ -189,8 +194,9 @@ int main(int argc, char* argv[]) {
while (body_received < body_target) {
result = amqp_simple_wait_frame(conn, &frame);
- if (result < 0)
+ if (result < 0) {
break;
+ }
if (frame.frame_type != AMQP_FRAME_BODY) {
fprintf(stderr, "Expected body!");