diff --git a/zulia-server/src/main/java/io/zulia/server/cmd/zuliaadmin/ConnectionInfo.java b/zulia-server/src/main/java/io/zulia/server/cmd/zuliaadmin/ConnectionInfo.java index 341702f8..b9821f7f 100644 --- a/zulia-server/src/main/java/io/zulia/server/cmd/zuliaadmin/ConnectionInfo.java +++ b/zulia-server/src/main/java/io/zulia/server/cmd/zuliaadmin/ConnectionInfo.java @@ -12,8 +12,11 @@ public class ConnectionInfo { @CommandLine.Option(names = "--port", description = "Zulia Port") public Integer port = 32191; + @CommandLine.Option(names = "--routing", description = "Use smart routing to route request to the correct node (do not use with ssh port forwarding)") + public boolean routingEnabled; + public ZuliaWorkPool getConnection() throws Exception { - ZuliaPoolConfig config = new ZuliaPoolConfig().addNode(address, port).setRoutingEnabled(false); + ZuliaPoolConfig config = new ZuliaPoolConfig().addNode(address, port).setRoutingEnabled(routingEnabled); return new ZuliaWorkPool(config); }