From a2ce8e7118e6fa49f1359d97135f92657fbd8520 Mon Sep 17 00:00:00 2001 From: Amit Kumar Mondal Date: Thu, 30 Nov 2023 15:14:40 +0100 Subject: [PATCH] Updated Formatting --- .../MessageReplyToManyHandlerTest.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/in.bytehue.messaging.mqtt5.provider/src/test/java/in/bytehue/messaging/mqtt5/provider/MessageReplyToManyHandlerTest.java b/in.bytehue.messaging.mqtt5.provider/src/test/java/in/bytehue/messaging/mqtt5/provider/MessageReplyToManyHandlerTest.java index 9c6e6a3..26800a7 100644 --- a/in.bytehue.messaging.mqtt5.provider/src/test/java/in/bytehue/messaging/mqtt5/provider/MessageReplyToManyHandlerTest.java +++ b/in.bytehue.messaging.mqtt5.provider/src/test/java/in/bytehue/messaging/mqtt5/provider/MessageReplyToManyHandlerTest.java @@ -95,7 +95,7 @@ public void test_reply_to_many_subscription_handler() throws Exception { final String targetValue = "(&(osgi.messaging.protocol=mqtt5)(osgi.messaging.name=mqtt5-hivemq-adapter)(osgi.messaging.feature=replyTo))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -152,7 +152,7 @@ public void test_reply_to_many_subscription_handler_without_protocol_name_in_tar final String targetValue = "(&(osgi.messaging.name=mqtt5-hivemq-adapter)(osgi.messaging.feature=replyTo))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -207,7 +207,7 @@ public void test_reply_to_many_subscription_handler_without_messaging_name_in_ta final String targetValue = "(&(osgi.messaging.protocol=mqtt5)(osgi.messaging.feature=replyTo))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -259,10 +259,10 @@ public void test_reply_to_many_subscription_handler_without_feature_in_target_ke return provider.createStream(source); }; final String targetKey = "osgi.messaging.replyToSubscription.target"; - final String targetValue = "(&(osgi.messaging.protocol=mqtt5)(osgi.messaging.name=mqtt5-hivemq-adapter))"; + final String targetValue = "(&(osgi.messaging.protocol=mqtt5)(osgi.messaging.name=mqtt5-hivemq-adapter)(osgi.messaging.feature=replyTo))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -317,7 +317,7 @@ public void test_reply_to_many_subscription_handler_with_different_feature_in_ta final String targetValue = "(&(osgi.messaging.protocol=mqtt5)(osgi.messaging.name=mqtt5-hivemq-adapter)(osgi.messaging.feature=abc))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -372,7 +372,7 @@ public void test_reply_to_many_subscription_handler_with_different_messaging_nam final String targetValue = "(&(osgi.messaging.protocol=mqtt5)(osgi.messaging.name=blahblah)(osgi.messaging.feature=replyTo))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -427,7 +427,7 @@ public void test_reply_to_many_subscription_handler_with_different_protocol_in_t final String targetValue = "(&(osgi.messaging.protocol=amqp)(osgi.messaging.name=mqtt5-hivemq-adapter)(osgi.messaging.feature=replyTo))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -479,7 +479,7 @@ public void test_reply_to_many_subscription_handler_without_target_key() throws return provider.createStream(source); }; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; final String replyToChannelKey = "osgi.messaging.replyToSubscription.replyChannel"; final String replyToChannelValue = replyToChannel; @@ -586,7 +586,7 @@ public void test_reply_to_many_subscription_handler_without_reply_to_channel_key final String targetValue = "(&(osgi.messaging.protocol=mqtt5)(osgi.messaging.name=mqtt5-hivemq-adapter)(osgi.messaging.feature=replyTo))"; final String channelKey = "osgi.messaging.replyToSubscription.channel"; - final String[] channelValue = new String[] { channel }; + final String[] channelValue = { channel }; launchpad.register(ReplyToManySubscriptionHandler.class, handler, targetKey, targetValue, channelKey, channelValue);