From 8b448c6a0d073376614928a18eed101092d3044a Mon Sep 17 00:00:00 2001 From: Alan Antonuk Date: Mon, 1 Sep 2014 17:20:07 -0700 Subject: Print message body in amqp[s]_listen[q] examples. This fixes #199. --- examples/amqp_listen.c | 3 +++ examples/amqp_listenq.c | 3 +++ examples/amqps_listen.c | 3 +++ examples/amqps_listenq.c | 3 +++ 4 files changed, 12 insertions(+) (limited to 'examples') diff --git a/examples/amqp_listen.c b/examples/amqp_listen.c index ca7d538..3f86830 100644 --- a/examples/amqp_listen.c +++ b/examples/amqp_listen.c @@ -126,6 +126,9 @@ int main(int argc, char const *const *argv) (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_destroy_envelope(&envelope); } diff --git a/examples/amqp_listenq.c b/examples/amqp_listenq.c index b2e8094..3735645 100644 --- a/examples/amqp_listenq.c +++ b/examples/amqp_listenq.c @@ -107,6 +107,9 @@ int main(int argc, char const *const *argv) (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_destroy_envelope(&envelope); } diff --git a/examples/amqps_listen.c b/examples/amqps_listen.c index 44bb88c..fe1b86f 100644 --- a/examples/amqps_listen.c +++ b/examples/amqps_listen.c @@ -143,6 +143,9 @@ int main(int argc, char const *const *argv) (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_destroy_envelope(&envelope); } diff --git a/examples/amqps_listenq.c b/examples/amqps_listenq.c index 6643500..b00b50e 100644 --- a/examples/amqps_listenq.c +++ b/examples/amqps_listenq.c @@ -124,6 +124,9 @@ int main(int argc, char const *const *argv) (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_destroy_envelope(&envelope); } -- cgit v1.2.1