public DynamoDBReplicationEmitter()

in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java [190:206]

• 16 lines of code
• 6 McCabe index (conditional complexity)

    public DynamoDBReplicationEmitter(final String applicationName, final String endpoint, final String region, final String tableName,
                                      final AmazonDynamoDBAsync dynamoDBAsync, final AmazonCloudWatchAsync cloudwatch) {
        this.applicationName = applicationName;
        this.endpoint = endpoint;
        this.region = region;
        this.tableName = tableName;

        final boolean setDynamoDB = DYNAMODB.compareAndSet(null, dynamoDBAsync);
        if (setDynamoDB && dynamoDBAsync != null) {
            DYNAMODB.get().setEndpoint(endpoint);
        }
        final boolean setCloudWatch = CLOUDWATCH.compareAndSet(null, cloudwatch);
        if (setCloudWatch && cloudwatch != null) {
            CLOUDWATCH.get().setRegion(Regions.getCurrentRegion() == null ? Region.getRegion(Regions.US_EAST_1) : Regions.getCurrentRegion());
        }
        skipErrors = false; // TODO make configurable
    }