protected void emitCloudWatchMetrics()

in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java [110:117]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    protected void emitCloudWatchMetrics() {
        if (null != getCloudwatch()) {
            // TODO Emit CloudWatch metrics about the size of the queue of writes
            MetricDatum recordsProcessedDatum = new MetricDatum().withValue(getProcessedRecords());
            PutMetricDataRequest request = new PutMetricDataRequest().withMetricData(recordsProcessedDatum);
            getCloudwatch().putMetricData(request);
        }
    }