Added some trace logs

amitjoy · Nov 5, 2024 · 895d29f · 895d29f
1 parent 515fa27
commit 895d29f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/....provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessagePublisherProvider.java b/....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/...ovider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageSubscriptionProvider.java b/...ovider/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,