diff --git a/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitAnnotationDrivenConfiguration.java b/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitAnnotationDrivenConfiguration.java index ebbf2933ff1..2bff6719ddd 100644 --- a/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitAnnotationDrivenConfiguration.java +++ b/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitAnnotationDrivenConfiguration.java @@ -20,12 +20,10 @@ import org.springframework.amqp.rabbit.annotation.EnableRabbit; import org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils; import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; -import org.springframework.transaction.PlatformTransactionManager; /** * Configuration for Spring AMQP annotation driven endpoints. @@ -37,19 +35,12 @@ import org.springframework.transaction.PlatformTransactionManager; @ConditionalOnClass(EnableRabbit.class) class RabbitAnnotationDrivenConfiguration { - @Autowired(required = false) - private PlatformTransactionManager transactionManager; - @Bean @ConditionalOnMissingBean(name = "rabbitListenerContainerFactory") public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory( ConnectionFactory connectionFactory, RabbitProperties config) { SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); - if (this.transactionManager != null - && config.getListener().isUseTransactionManager()) { - factory.setTransactionManager(this.transactionManager); - } return factory; } diff --git a/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitProperties.java b/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitProperties.java index 83cabdc7886..773253d8312 100644 --- a/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitProperties.java +++ b/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitProperties.java @@ -62,12 +62,6 @@ public class RabbitProperties { */ private String addresses; - private Listener listener = new Listener(); - - public Listener getListener() { - return this.listener; - } - public String getHost() { if (this.addresses == null) { return this.host; @@ -162,16 +156,4 @@ public class RabbitProperties { this.virtualHost = ("".equals(virtualHost) ? "/" : virtualHost); } - public static class Listener { - private boolean useTransactionManager = false; - - public boolean isUseTransactionManager() { - return this.useTransactionManager; - } - - public void setUseTransactionManager(boolean useTransactionManager) { - this.useTransactionManager = useTransactionManager; - } - } - }