diff --git a/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java b/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java index 769f93f5d..9eb552824 100644 --- 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,7 +105,6 @@ void resubscribeShardChannelSubscription() { assertInstanceOf(AsyncCommand.class, commandFuture); } - @Test void resubscribeChannelAndPatternAndShardChanelSubscription() { when(mockedEndpoint.hasChannelSubscriptions()).thenReturn(true); @@ -112,7 +112,8 @@ void resubscribeChannelAndPatternAndShardChanelSubscription() { 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> subscriptions = connection.resubscribe(); assertEquals(3, subscriptions.size());