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

Commit c15e345

Browse files
authored
GH-187 INFO for error when KinesisChA is inactive
Fixes #187
1 parent eed4a62 commit c15e345

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

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

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -671,7 +671,14 @@ private void sleep(long sleepAmount, RuntimeException error, boolean interruptTh
671671
if (interruptThread) {
672672
Thread.currentThread().interrupt();
673673
}
674-
logger.error(error.getMessage(), e);
674+
675+
if (this.active) {
676+
logger.error(error.getMessage(), e);
677+
}
678+
else {
679+
logger.info(error.getMessage() + " while adapter was inactive", e);
680+
}
681+
675682
throw error;
676683
}
677684
}

0 commit comments

Comments
 (0)