public static void main(String[] args) throws InterruptedException {

        final ByteSizeValue payloadSize = new ByteSizeValue(10, ByteSizeUnit.MB);

        final int NUMBER_OF_ITERATIONS = 100000;

        final int NUMBER_OF_CLIENTS = 5;

        Settings settings = ImmutableSettings.settingsBuilder()

                .build();

        final ThreadPool threadPool = new ThreadPool();

        final boolean waitForRequest = true;

        final ByteSizeValue payloadSize = new ByteSizeValue(100, ByteSizeUnit.BYTES);

        final int NUMBER_OF_CLIENTS = 1;

        final int NUMBER_OF_ITERATIONS = 100000;

        final AtomicLong idGenerator = new AtomicLong();

        final Type type = Type.NETTY;

        Settings settings = ImmutableSettings.settingsBuilder()

            if (indexingBuffer.bytes() < minIndexingBuffer.bytes()) {

                indexingBuffer = minIndexingBuffer;

            }

                indexingBuffer = maxIndexingBuffer;

            }

        } else {

            indexingBuffer = ByteSizeValue.parseBytesSizeValue(indexingBufferSetting, null);

        }

        ByteSizeValue shardIndexingBufferSize = calcShardIndexingBuffer(shardsCount);

        if (shardIndexingBufferSize == null) {

            return;

        }

            shardIndexingBufferSize = minShardIndexBufferSize;

        }

        if (shardIndexingBufferSize.bytes() > maxShardIndexBufferSize.bytes()) {

            shardIndexingBufferSize = maxShardIndexBufferSize;

        }

        }

        if (shardIndexingBufferSize.bytes() < minShardIndexBufferSize.bytes()) {

            shardIndexingBufferSize = minShardIndexBufferSize;

        }

            shardIndexingBufferSize = maxShardIndexBufferSize;

        }

        logger.debug("recalculating shard indexing buffer (reason={}), total is [{}] with [{}] active shards, each shard set to [{}]", reason, indexingBuffer, shardsCount, shardIndexingBufferSize);

        for (IndexService indexService : indicesService) {

            for (IndexShard indexShard : indexService) {

        this.compression = settings.getAsBoolean("http.compression", true);

        this.compressionLevel = settings.getAsInt("http.compression_level", 6);

        // validate max content length

            logger.warn("maxContentLength[" + maxContentLength + "] set to high value, resetting it to [100mb]");

            maxContentLength = new ByteSizeValue(100, ByteSizeUnit.MB);

        }

        this.maxContentLength = maxContentLength;

    compression = settings.getAsBoolean("http.compression", false);

    compressionLevel = settings.getAsInt("http.compression_level", 6);

    // validate max content length

      logger.warn("maxContentLength[" + maxContentLength

          + "] set to high value, resetting it to [100mb]");

      maxContentLength = new ByteSizeValue(100, ByteSizeUnit.MB);

    }

    this.maxContentLength = maxContentLength;

        // See AdaptiveReceiveBufferSizePredictor#DEFAULT_XXX for default values in netty..., we can use higher ones for us, even fixed one

        ByteSizeValue receivePredictorMin = componentSettings.getAsBytesSize("receive_predictor_min", componentSettings.getAsBytesSize("receive_predictor_size", new ByteSizeValue(defaultReceiverPredictor)));

        ByteSizeValue receivePredictorMax = componentSettings.getAsBytesSize("receive_predictor_max", componentSettings.getAsBytesSize("receive_predictor_size", new ByteSizeValue(defaultReceiverPredictor)));

            receiveBufferSizePredictorFactory = new FixedReceiveBufferSizePredictorFactory((int) receivePredictorMax.bytes());

        } else {

            receiveBufferSizePredictorFactory = new AdaptiveReceiveBufferSizePredictorFactory((int) receivePredictorMin.bytes(), (int) receivePredictorMin.bytes(), (int) receivePredictorMax.bytes());

        }

        // See AdaptiveReceiveBufferSizePredictor#DEFAULT_XXX for default values in netty..., we can use higher ones for us, even fixed one

        ByteSizeValue receivePredictorMin = componentSettings.getAsBytesSize("receive_predictor_min", componentSettings.getAsBytesSize("receive_predictor_size", new ByteSizeValue(defaultReceiverPredictor)));

        ByteSizeValue receivePredictorMax = componentSettings.getAsBytesSize("receive_predictor_max", componentSettings.getAsBytesSize("receive_predictor_size", new ByteSizeValue(defaultReceiverPredictor)));

        if (receivePredictorMax.bytes() == receivePredictorMin.bytes()) {

        } else {

            receiveBufferSizePredictorFactory = new AdaptiveReceiveBufferSizePredictorFactory((int) receivePredictorMin.bytes(), (int) receivePredictorMin.bytes(), (int) receivePredictorMax.bytes());

        }

        logger.debug("using worker_count[{}], port[{}], bind_host[{}], publish_host[{}], compress[{}], connect_timeout[{}], connections_per_node[{}/{}/{}/{}/{}], receive_predictor[{}->{}]",

        ByteSizeValue receivePredictorMax = componentSettings.getAsBytesSize("receive_predictor_max", componentSettings.getAsBytesSize("receive_predictor_size", new ByteSizeValue(defaultReceiverPredictor)));

        if (receivePredictorMax.bytes() == receivePredictorMin.bytes()) {

            receiveBufferSizePredictorFactory = new FixedReceiveBufferSizePredictorFactory((int) receivePredictorMax.bytes());

        } else {

        }

        logger.debug("using worker_count[{}], port[{}], bind_host[{}], publish_host[{}], compress[{}], connect_timeout[{}], connections_per_node[{}/{}/{}/{}/{}], receive_predictor[{}->{}]",

                workerCount, port, bindHost, publishHost, compress, connectTimeout, connectionsPerNodeRecovery, connectionsPerNodeBulk, connectionsPerNodeReg, connectionsPerNodeState, connectionsPerNodePing, receivePredictorMin, receivePredictorMax);

    }