We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c3d7624 commit 226e6b5Copy full SHA for 226e6b5
spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/RabbitStreamTemplate.java
@@ -110,7 +110,7 @@ public void setMessageConverter(MessageConverter messageConverter) {
110
* for {@link #send(Message)} and {@link #convertAndSend(Object)} methods.
111
* @param streamConverter the converter.
112
*/
113
- public void setStreamConverter(StreamMessageConverter streamConverter) {
+ public synchronized void setStreamConverter(StreamMessageConverter streamConverter) {
114
Assert.notNull(streamConverter, "'streamConverter' cannot be null");
115
this.streamConverter = streamConverter;
116
this.streamConverterSet = true;
0 commit comments