in src/main/java/com/amazonaws/services/dynamodbv2/streamsadapter/DynamoDBStreamsProxy.java [110:136]
private DynamoDBStreamsProxy(final String streamName,
AWSCredentialsProvider credentialProvider,
AmazonKinesis kinesisClient,
long describeStreamBackoffTimeInMillis,
int maxDescribeStreamRetryAttempts,
int maxRetriesToResolveInconsistencies,
long inconsistencyResolutionRetryBackoffBaseInMillis,
long inconsistencyResolutionRetryBackoffMultiplierInMillis,
boolean isDefaultInconsistencyResolutionRetryBackoffJitterEnabled,
Sleeper sleeper,
Random random) {
this.streamName = streamName;
this.credentialsProvider = credentialProvider;
this.describeStreamBackoffTimeInMillis = describeStreamBackoffTimeInMillis;
this.maxDescribeStreamRetryAttempts = maxDescribeStreamRetryAttempts;
this.maxRetriesToResolveInconsistencies = maxRetriesToResolveInconsistencies;
this.inconsistencyResolutionRetryBackoffBaseInMillis = inconsistencyResolutionRetryBackoffBaseInMillis;
this.inconsistencyResolutionRetryBackoffMultiplierInMillis
= inconsistencyResolutionRetryBackoffMultiplierInMillis;
this.isInconsistencyResolutionRetryBackoffJitterEnabled
= isDefaultInconsistencyResolutionRetryBackoffJitterEnabled;
this.client = kinesisClient;
this.sleeper = sleeper;
this.random = random;
LOG.debug("DynamoDBStreamsProxy( " + streamName + ")");
}