Skip to content

Commit 583a1e7

Browse files
committed
putting things back
1 parent 03ad634 commit 583a1e7

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -680,16 +680,16 @@ private final class ListenerConsumer implements SchedulingAwareRunnable, Consume
680680

681681
private final @Nullable CommonErrorHandler commonErrorHandler;
682682

683+
@Deprecated(since = "3.2", forRemoval = true)
683684
@SuppressWarnings("removal")
684685
private final @Nullable PlatformTransactionManager transactionManager =
685686
this.containerProperties.getKafkaAwareTransactionManager() != null ?
686687
this.containerProperties.getKafkaAwareTransactionManager() :
687688
this.containerProperties.getTransactionManager();
688689

689690
private final @Nullable KafkaAwareTransactionManager<?, ?> kafkaTxManager =
690-
this.transactionManager instanceof KafkaAwareTransactionManager
691-
? (KafkaAwareTransactionManager<?, ?>) this.transactionManager
692-
: null;
691+
this.transactionManager instanceof KafkaAwareTransactionManager<?, ?> kafkaAwareTransactionManager ?
692+
kafkaAwareTransactionManager : null;
693693

694694
private final @Nullable TransactionTemplate transactionTemplate;
695695

0 commit comments

Comments
 (0)