if (!config.getBoolean(ServerConfig.Key.QUERY_ENABLED)) {
return;
}
SocketAddress address = getBindAddress(ServerConfig.Key.QUERY_PORT);
queryServer = new QueryServer(this, config.getBoolean(ServerConfig.Key.QUERY_PLUGINS));
logger.info("Binding query to address: " + address + "...");
ChannelFuture future = queryServer.bind(address);
Channel channel = future.awaitUninterruptibly().channel();
if (!channel.isActive()) {