Make RabbitStreamTemplate.producer as volatile

spring-projects · Oct 21, 2024 · f150bf5 · f150bf5
1 parent b1c6893
commit f150bf5
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java b/...stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java
@@ -79,8 +79,6 @@ public class RabbitStreamTemplate implements RabbitStreamOperations, Application
 
 	private boolean streamConverterSet;
 
-	private Producer producer;
-
 	private String beanName;
 
 	private ProducerCustomizer producerCustomizer = (name, builder) -> { };
@@ -90,10 +88,12 @@ public class RabbitStreamTemplate implements RabbitStreamOperations, Application
 	@Nullable
 	private RabbitStreamTemplateObservationConvention observationConvention;
 
-	private volatile boolean observationRegistryObtained;
-
 	private ObservationRegistry observationRegistry;
 
+	private volatile Producer producer;
+
+	private volatile boolean observationRegistryObtained;
+
 	/**
 	 * Construct an instance with the provided {@link Environment}.
 	 * @param environment the environment.