luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixing factory in leasemanagementconfig.

Browse source
This commit is contained in:
Sahil Palvia 2018-03-22 14:35:17 -07:00 committed by Justin Pfifer
parent dbbc306fef
commit dffe9194f2
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
View file

@ -183,11 +183,11 @@ public class LeaseManagementConfig {
public LeaseManagementFactory leaseManagementFactory() {
if (leaseManagementFactory == null) {
new DynamoDBLeaseManagementFactory(workerIdentifier(), failoverTimeMillis(), EPSILON_MS,
maxLeasesForWorker(), maxLeasesToStealAtOneTime(), maxLeaseRenewalThreads(), kinesisProxy(),
initialPositionInStream(), cleanupLeasesUponShardCompletion(), ignoreUnexpectedChildShards(),
shardSyncIntervalMillis(), metricsFactory(), executorService(), tableName(), amazonDynamoDB(),
consistentReads());
leaseManagementFactory = new DynamoDBLeaseManagementFactory(workerIdentifier(), failoverTimeMillis(),
EPSILON_MS, maxLeasesForWorker(), maxLeasesToStealAtOneTime(), maxLeaseRenewalThreads(),
kinesisProxy(), initialPositionInStream(), cleanupLeasesUponShardCompletion(),
ignoreUnexpectedChildShards(), shardSyncIntervalMillis(), metricsFactory(), executorService(),
tableName(), amazonDynamoDB(), consistentReads());
}
return leaseManagementFactory;
}