From 257b79728b7ad71cb626103fd2e3dc6f5d7ea171 Mon Sep 17 00:00:00 2001 From: Allysson Lukas Date: Tue, 2 Jun 2020 17:25:06 -0300 Subject: [PATCH] Improve logs on mq source Improve logs on mq source when receiving and sending a message. --- src/mq.c | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/mq.c b/src/mq.c index 0b486c0..b3e17af 100644 --- a/src/mq.c +++ b/src/mq.c @@ -125,14 +125,12 @@ static bool on_receive(struct l_io *io, void *user_data) if (res.reply_type != AMQP_RESPONSE_NORMAL) return true; - l_debug("Receive %u, exchange %.*s routingkey %.*s", + l_debug("Receive %u -> exchange: %.*s, routingkey: %.*s\nBody: %.*s\n", (unsigned int)envelope.delivery_tag, (int)envelope.exchange.len, (char *)envelope.exchange.bytes, (int)envelope.routing_key.len, - (char *)envelope.routing_key.bytes); - - l_debug("Body: %.*s", + (char *)envelope.routing_key.bytes, (int)envelope.message.body.len, (char *)envelope.message.body.bytes); @@ -349,6 +347,11 @@ int8_t mq_publish_persistent_message(amqp_bytes_t queue, props.content_type = amqp_cstring_bytes("text/plain"); props.delivery_mode = AMQP_DELIVERY_PERSISTENT; + l_debug("Publish -> exchange: %s, routingkey: %s\nBody: %s\n", + exchange, + routing_keys, + body); + rc = amqp_basic_publish(mq_ctx.conn, 1, amqp_cstring_bytes(exchange), amqp_cstring_bytes(routing_keys),