From 3ff3a3bd187db6fa3bfe973d9e4f97977ec2c3e8 Mon Sep 17 00:00:00 2001 From: Amit Kumar Mondal Date: Mon, 11 Nov 2024 15:55:34 +0100 Subject: [PATCH] Added missing //NOSONAR tag --- .../mqtt5/provider/MessageSubscriptionProvider.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) 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 47183c2..623d575 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 @@ -123,11 +123,11 @@ public PushStream 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 } }