From dffe9194f206d63508d388f94cf4895321ec1f95 Mon Sep 17 00:00:00 2001
From: Sahil Palvia <spalvia@amazon.com>
Date: Thu, 22 Mar 2018 14:35:17 -0700
Subject: [PATCH] Fixing factory in leasemanagementconfig.

---
 .../amazon/kinesis/leases/LeaseManagementConfig.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
index 30c564cb..61606aef 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
@@ -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;
     }