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
parent 605dfa2b42
commit 56e13c0188
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() { public LeaseManagementFactory leaseManagementFactory() {
if (leaseManagementFactory == null) { if (leaseManagementFactory == null) {
new DynamoDBLeaseManagementFactory(workerIdentifier(), failoverTimeMillis(), EPSILON_MS, leaseManagementFactory = new DynamoDBLeaseManagementFactory(workerIdentifier(), failoverTimeMillis(),
maxLeasesForWorker(), maxLeasesToStealAtOneTime(), maxLeaseRenewalThreads(), kinesisProxy(), EPSILON_MS, maxLeasesForWorker(), maxLeasesToStealAtOneTime(), maxLeaseRenewalThreads(),
initialPositionInStream(), cleanupLeasesUponShardCompletion(), ignoreUnexpectedChildShards(), kinesisProxy(), initialPositionInStream(), cleanupLeasesUponShardCompletion(),
shardSyncIntervalMillis(), metricsFactory(), executorService(), tableName(), amazonDynamoDB(), ignoreUnexpectedChildShards(), shardSyncIntervalMillis(), metricsFactory(), executorService(),
consistentReads()); tableName(), amazonDynamoDB(), consistentReads());
} }
return leaseManagementFactory; return leaseManagementFactory;
} }