From 895d29f0b05041373259272f7576770bf4694397 Mon Sep 17 00:00:00 2001 From: Amit Kumar Mondal Date: Thu, 10 Oct 2024 11:49:59 +0200 Subject: [PATCH] Added some trace logs --- .../messaging/mqtt5/provider/MessagePublisherProvider.java | 1 + .../messaging/mqtt5/provider/MessageSubscriptionProvider.java | 1 + 2 files changed, 2 insertions(+) diff --git a/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessagePublisherProvider.java b/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessagePublisherProvider.java index cdbc892..1caabf9 100644 --- a/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessagePublisherProvider.java +++ b/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessagePublisherProvider.java @@ -193,6 +193,7 @@ private void publish(final Message message, MessageContext context, String chann logger.error("Error occurred while publishing message", throwable); } else if (isPublishSuccessful(result)) { resultFuture.complete(null); + logger.trace("Successful Publish Request: {} ", result); logger.trace("New publish request for '{}' has been processed successfully", ch); } else { final Throwable t = result.getError().get(); diff --git a/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageSubscriptionProvider.java b/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageSubscriptionProvider.java index d84217b..7ab8b13 100644 --- a/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageSubscriptionProvider.java +++ b/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageSubscriptionProvider.java @@ -193,6 +193,7 @@ private SubscriptionAck subscribe( final MessageContextBuilderProvider mcb = mcbFactory.getService(); try { final Message message = toMessage(p, ctx, mcb); + logger.trace("Successful Subscription Response: {} ", message); acknowledgeMessage( message, ctx,