diff --git a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java index 33926f5e..201abed3 100644 --- a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java +++ b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/listener/StreamListenerContainer.java @@ -130,7 +130,7 @@ public class StreamListenerContainer implements MessageListenerContainer, BeanNa * @param consumers the number of consumers. * @since 3.0 */ - public void superStream(String streamName, String name, int consumers) { + public synchronized void superStream(String streamName, String name, int consumers) { Assert.isTrue(consumers > 0, () -> "'concurrency' must be greater than zero, not " + consumers); this.concurrency = consumers; Assert.isTrue(!this.simpleStream, "setQueueNames() and superStream() are mutually exclusive"); diff --git a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java index 418c22bf..2c7c71bf 100644 --- a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java +++ b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java @@ -110,7 +110,7 @@ public class RabbitStreamTemplate implements RabbitStreamOperations, BeanNameAwa * @param superStreamRouting the routing function. * @since 3.0 */ - public void setSuperStreamRouting(Function superStreamRouting) { + public synchronized void setSuperStreamRouting(Function superStreamRouting) { this.superStreamRouting = superStreamRouting; } diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/annotation/RabbitListenerAnnotationBeanPostProcessor.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/annotation/RabbitListenerAnnotationBeanPostProcessor.java index 1c7da2ae..02a76135 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/annotation/RabbitListenerAnnotationBeanPostProcessor.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/annotation/RabbitListenerAnnotationBeanPostProcessor.java @@ -1126,9 +1126,9 @@ public class RabbitListenerAnnotationBeanPostProcessor } TypeMetadata(ListenerMethod[] methods, Method[] multiMethods, RabbitListener[] classLevelListeners) { // NOSONAR - this.listenerMethods = methods; - this.handlerMethods = multiMethods; - this.classAnnotations = classLevelListeners; + this.listenerMethods = methods; // NOSONAR + this.handlerMethods = multiMethods; // NOSONAR + this.classAnnotations = classLevelListeners; // NOSONAR } } @@ -1144,7 +1144,7 @@ public class RabbitListenerAnnotationBeanPostProcessor ListenerMethod(Method method, RabbitListener[] annotations) { // NOSONAR this.method = method; - this.annotations = annotations; + this.annotations = annotations; // NOSONAR } } diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/BindingFactoryBean.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/BindingFactoryBean.java index af8ca15a..1796d0ad 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/BindingFactoryBean.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/BindingFactoryBean.java @@ -77,7 +77,7 @@ public class BindingFactoryBean implements FactoryBean { } public void setAdminsThatShouldDeclare(AmqpAdmin... admins) { // NOSONAR - this.adminsThatShouldDeclare = admins; + this.adminsThatShouldDeclare = admins; // NOSONAR } @Override diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerFactoryBean.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerFactoryBean.java index bbe884e2..a23d29ca 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerFactoryBean.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/ListenerContainerFactoryBean.java @@ -212,11 +212,11 @@ public class ListenerContainerFactoryBean extends AbstractFactoryBean