Added missing //NOSONAR tag

amitjoy · Nov 14, 2024 · 3ff3a3b · 3ff3a3b
1 parent 463b6c4
commit 3ff3a3b
Showing 1 changed file with 6 additions and 6 deletions.
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
@@ -123,11 +123,11 @@ public PushStream<Message> subscribe(final MessageContext context) {
         return _subscribe(context).stream();
     }
 
-    public SubscriptionAck _subscribe(final String subChannel) {
+    public SubscriptionAck _subscribe(final String subChannel) { //NOSONAR
     	return subscribe(null, subChannel, null, false);
     }
 
-    public SubscriptionAck _subscribe(final MessageContext context) {
+    public SubscriptionAck _subscribe(final MessageContext context) { //NOSONAR
     	return subscribe(context, context.getChannel(), null, false);
     }
 
@@ -191,7 +191,7 @@ private SubscriptionAck subscribe(
 										                                  .callback(p -> {
 										                                	  try {
 										                                		  final MessageContextBuilderProvider mcb = mcbFactory.getService();
-											                                	  try {
+											                                	  try { //NOSONAR
 											                                		  final Message message = toMessage(p, ctx, mcb);
 											                                		  logger.trace("Successful Subscription Response: {} ", message);
 											                                              acknowledgeMessage(
@@ -227,10 +227,10 @@ private SubscriptionAck subscribe(
             return SubscriptionAck.of(stream, subscription.id);
         } catch (final ExecutionException e) {
             logger.error("Error while subscribing to {}", sChannel, e);
-            throw new RuntimeException(e.getCause());
-        } catch (final Exception e) {
+            throw new RuntimeException(e.getCause()); //NOSONAR
+        } catch (final Exception e) { //NOSONAR
             logger.error("Error while subscribing to {}", sChannel, e);
-            throw new RuntimeException(e);
+            throw new RuntimeException(e); //NOSONAR
         }
     }