Skip to content

Commit

Permalink
Updated Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
@amitjoy
amitjoy committed Nov 30, 2023
1 parent 0580805 commit a2ce8e7
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions ...ider/src/test/java/in/bytehue/messaging/mqtt5/provider/MessageReplyToManyHandlerTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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);
Expand Down

0 comments on commit a2ce8e7

Please sign in to comment.