Skip to content
This repository was archived by the owner on Nov 10, 2025. It is now read-only.

Commit 526353c

Browse files
committed
Kinesis CA: Fulfill lockFuture on exception
Related to spring-cloud/spring-cloud-stream-binder-aws-kinesis#148 When `lock.tryLock()` ends up with an exception, we just log it under error category. * Add also `lockFuture.complete(false)` in the catch block when we try to renew the lock
1 parent ac74dfd commit 526353c

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1506,6 +1506,7 @@ public void run() {
15061506
}
15071507
}
15081508
catch (Exception e) {
1509+
lockFuture.complete(false);
15091510
logger.error("Error during locking: " + lock, e);
15101511
}
15111512
}

0 commit comments

Comments
 (0)