diff --git a/java/client/src/main/java/babushka/connectors/handlers/ChannelHandler.java b/java/client/src/main/java/babushka/connectors/handlers/ChannelHandler.java index 1cd11f12e8..80f04839c0 100644 --- a/java/client/src/main/java/babushka/connectors/handlers/ChannelHandler.java +++ b/java/client/src/main/java/babushka/connectors/handlers/ChannelHandler.java @@ -24,6 +24,7 @@ public class ChannelHandler { public ChannelHandler(CallbackManager callbackManager, String socketPath) { channel = new Bootstrap() + // TODO let user specify the thread pool or pool size as an option .group(Platform.createNettyThreadPool("babushka-channel", OptionalInt.empty())) .channel(Platform.getClientUdsNettyChannelType()) .handler(new ProtobufSocketChannelInitializer(callbackManager))