Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make RabbitStreamTemplate.producer as volatile

Browse Source
This commit is contained in:
Artem Bilan
2024-10-21 17:47:49 -04:00
parent b1c6893e31
commit f150bf531a
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java
View File

@@ -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.