protected Message toProtobufMessage()

in java/amazon-kinesis-producer/src/main/java/com/amazonaws/services/kinesis/producer/KinesisProducerConfiguration.java [1602:1642]

38 lines of code
2 McCabe index (conditional complexity)


    protected Message toProtobufMessage() {
        Configuration.Builder builder = Configuration.newBuilder()
                //@formatter:off
                .setAggregationEnabled(aggregationEnabled)
                .setAggregationMaxCount(aggregationMaxCount)
                .setAggregationMaxSize(aggregationMaxSize)
                .setCloudwatchEndpoint(cloudwatchEndpoint)
                .setCloudwatchPort(cloudwatchPort)
                .setCollectionMaxCount(collectionMaxCount)
                .setCollectionMaxSize(collectionMaxSize)
                .setConnectTimeout(connectTimeout)
                .setEnableCoreDumps(enableCoreDumps)
                .setFailIfThrottled(failIfThrottled)
                .setKinesisEndpoint(kinesisEndpoint)
                .setKinesisPort(kinesisPort)
                .setLogLevel(logLevel)
                .setMaxConnections(maxConnections)
                .setMetricsGranularity(metricsGranularity)
                .setMetricsLevel(metricsLevel)
                .setMetricsNamespace(metricsNamespace)
                .setMetricsUploadDelay(metricsUploadDelay)
                .setMinConnections(minConnections)
                .setRateLimit(rateLimit)
                .setRecordMaxBufferedTime(recordMaxBufferedTime)
                .setRecordTtl(recordTtl)
                .setRegion(region)
                .setRequestTimeout(requestTimeout)
                .setVerifyCertificate(verifyCertificate)
                .setProxyHost(proxyHost)
                .setProxyPort(proxyPort)
                .setProxyUserName(proxyUserName)
                .setProxyPassword(proxyPassword)
                .setThreadConfig(threadingModel.threadConfig);
        //@formatter:on
        if (threadPoolSize > 0) {
            builder = builder.setThreadPoolSize(threadPoolSize);
        }

        Configuration c = this.additionalConfigsToProtobuf(builder).build();
        return Message.newBuilder().setConfiguration(c).setId(0).build();
    }