diff --git a/java/client/src/main/java/glide/api/RedisClient.java b/java/client/src/main/java/glide/api/RedisClient.java index f6e461f298..557f5c8cf3 100644 --- a/java/client/src/main/java/glide/api/RedisClient.java +++ b/java/client/src/main/java/glide/api/RedisClient.java @@ -29,7 +29,8 @@ public class RedisClient extends BaseClient implements BaseCommands { public static CompletableFuture CreateClient(RedisClientConfiguration config) { ThreadPoolResource threadPoolResource = config.getThreadPoolResource(); if (threadPoolResource == null) { - threadPoolResource = ThreadPoolResourceAllocator.getOrCreate(Platform.getThreadPoolResourceSupplier()); + threadPoolResource = + ThreadPoolResourceAllocator.getOrCreate(Platform.getThreadPoolResourceSupplier()); } ChannelHandler channelHandler = buildChannelHandler(threadPoolResource); var connectionManager = buildConnectionManager(channelHandler); diff --git a/java/client/src/main/java/glide/connectors/resources/EpollResource.java b/java/client/src/main/java/glide/connectors/resources/EpollResource.java index 203a64b57a..f3a77deebc 100644 --- a/java/client/src/main/java/glide/connectors/resources/EpollResource.java +++ b/java/client/src/main/java/glide/connectors/resources/EpollResource.java @@ -15,8 +15,7 @@ public EpollResource() { this( new EpollEventLoopGroup( Runtime.getRuntime().availableProcessors(), - new DefaultThreadFactory(EPOLL_EVENT_LOOP_IDENTIFIER, true)) - ); + new DefaultThreadFactory(EPOLL_EVENT_LOOP_IDENTIFIER, true))); } public EpollResource(EpollEventLoopGroup epollEventLoopGroup) { diff --git a/java/client/src/main/java/glide/connectors/resources/KQueuePoolResource.java b/java/client/src/main/java/glide/connectors/resources/KQueuePoolResource.java index 2d1ce83c78..078e65a69e 100644 --- a/java/client/src/main/java/glide/connectors/resources/KQueuePoolResource.java +++ b/java/client/src/main/java/glide/connectors/resources/KQueuePoolResource.java @@ -15,8 +15,7 @@ public KQueuePoolResource() { this( new KQueueEventLoopGroup( Runtime.getRuntime().availableProcessors(), - new DefaultThreadFactory(KQUEUE_EVENT_LOOP_IDENTIFIER, true)) - ); + new DefaultThreadFactory(KQUEUE_EVENT_LOOP_IDENTIFIER, true))); } public KQueuePoolResource(KQueueEventLoopGroup eventLoopGroup) { diff --git a/java/client/src/main/java/glide/connectors/resources/Platform.java b/java/client/src/main/java/glide/connectors/resources/Platform.java index a5d50426fe..7ee62ebaf8 100644 --- a/java/client/src/main/java/glide/connectors/resources/Platform.java +++ b/java/client/src/main/java/glide/connectors/resources/Platform.java @@ -1,10 +1,7 @@ package glide.connectors.resources; import io.netty.channel.epoll.Epoll; -import io.netty.channel.epoll.EpollDomainSocketChannel; import io.netty.channel.kqueue.KQueue; -import io.netty.channel.kqueue.KQueueDomainSocketChannel; -import io.netty.channel.unix.DomainSocketChannel; import java.util.function.Supplier; import lombok.AccessLevel; import lombok.AllArgsConstructor;