GH-1845: Use stoppableSleep() for Authz Sleeps

garyrussell · garyrussell · commit f173887874ea · 2021-06-28T14:07:23.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -1447,7 +1447,7 @@ private void debugRecords(@Nullable ConsumerRecords<K, V> records) {
 
 		private void sleepFor(Duration duration) {
 			try {
-				TimeUnit.MILLISECONDS.sleep(duration.toMillis());
+				ListenerUtils.stoppableSleep(KafkaMessageListenerContainer.this, duration.toMillis());
 			}
 			catch (InterruptedException e) {
 				this.logger.error(e, "Interrupted while sleeping");

Original file line number	Diff line number	Diff line change
`@@ -1447,7 +1447,7 @@ private void debugRecords(@Nullable ConsumerRecords<K, V> records) {`
`1447`	`1447`
`1448`	`1448`	`private void sleepFor(Duration duration) {`
`1449`	`1449`	`try {`
`1450`		`- TimeUnit.MILLISECONDS.sleep(duration.toMillis());`
	`1450`	`+ ListenerUtils.stoppableSleep(KafkaMessageListenerContainer.this, duration.toMillis());`
`1451`	`1451`	`}`
`1452`	`1452`	`catch (InterruptedException e) {`
`1453`	`1453`	`this.logger.error(e, "Interrupted while sleeping");`