public KinesisProducer get()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisProducerProvider.java [38:66]

26 lines of code
1 McCabe index (conditional complexity)


  public KinesisProducer get() {
    KinesisProducerConfiguration conf =
        new KinesisProducerConfiguration()
            .setAggregationEnabled(false)
            .setMaxConnections(1)
            .setRequestTimeout(configuration.getPublishSingleRequestTimeoutMs());

    conf.setRegion(configuration.getRegion().orElseGet(regionProvider::getRegion).toString());

    configuration
        .getEndpoint()
        .ifPresent(
            uri ->
                conf.setKinesisEndpoint(uri.getHost())
                    .setKinesisPort(uri.getPort())
                    .setCloudwatchEndpoint(uri.getHost())
                    .setCloudwatchPort(uri.getPort())
                    .setVerifyCertificate(false));
    logger.atInfo().log(
        "Kinesis producer configured. Request Timeout (ms):'%s'%s%s",
        configuration.getPublishSingleRequestTimeoutMs(),
        String.format("|region: '%s'", conf.getRegion()),
        configuration
            .getEndpoint()
            .map(e -> String.format("|endpoint: '%s'", e.toASCIIString()))
            .orElse(""));

    return new KinesisProducer(conf);
  }