Skip to content

Commit 1a41ac6

Browse files
committed
Polishing for coverage commit
Avoid synthetic access method; add getter.
1 parent 53f5667 commit 1a41ac6

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -239,7 +239,7 @@ else if (partitionsListenerConsumer.assignedPartitions != null) {
239239

240240
@Override
241241
public boolean isContainerPaused() {
242-
return isPaused() && this.listenerConsumer != null && this.listenerConsumer.consumerPaused;
242+
return isPaused() && this.listenerConsumer != null && this.listenerConsumer.isConsumerPaused();
243243
}
244244

245245
@Override
@@ -560,6 +560,10 @@ else if (listener instanceof MessageListener) {
560560
}
561561
}
562562

563+
boolean isConsumerPaused() {
564+
return this.consumerPaused;
565+
}
566+
563567
@Nullable
564568
private TransactionTemplate determineTransactionTemplate() {
565569
return this.transactionManager != null

0 commit comments

Comments
 (0)