Formatiing

redis · Oct 24, 2024 · d4aee34 · d4aee34
1 parent 33d3483
commit d4aee34
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java b/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java
@@ -93,7 +93,8 @@ void resubscribeChannelSubscription() {
     @Test
     void resubscribeShardChannelSubscription() {
         when(mockedEndpoint.hasShardChannelSubscriptions()).thenReturn(true);
-        when(mockedEndpoint.getShardChannels()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
+        when(mockedEndpoint.getShardChannels())
+                .thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
         when(mockedEndpoint.hasChannelSubscriptions()).thenReturn(false);
         when(mockedEndpoint.hasPatternSubscriptions()).thenReturn(false);
 
@@ -104,15 +105,15 @@ void resubscribeShardChannelSubscription() {
         assertInstanceOf(AsyncCommand.class, commandFuture);
     }
 
-
     @Test
     void resubscribeChannelAndPatternAndShardChanelSubscription() {
         when(mockedEndpoint.hasChannelSubscriptions()).thenReturn(true);
         when(mockedEndpoint.hasPatternSubscriptions()).thenReturn(true);
         when(mockedEndpoint.hasShardChannelSubscriptions()).thenReturn(true);
         when(mockedEndpoint.getChannels()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "channel1", "channel2" })));
         when(mockedEndpoint.getPatterns()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "bcast*", "echo" })));
-        when(mockedEndpoint.getShardChannels()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
+        when(mockedEndpoint.getShardChannels())
+                .thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
         List<RedisFuture<Void>> subscriptions = connection.resubscribe();
 
         assertEquals(3, subscriptions.size());