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

GH-1352: Resolve one more Sonar issue

Browse Source
This commit is contained in:
Gary Russell
2021-06-21 14:30:03 -04:00
parent 5e2c557ee9
commit 3d72e07243
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/support/converter/DefaultStreamMessageConverter.java
View File

@@ -41,10 +41,13 @@ import com.rabbitmq.stream.codec.WrapperMessageBuilder;
*/
public class DefaultStreamMessageConverter implements StreamMessageConverter {
private final Supplier<MessageBuilder> builder;
private final Supplier<MessageBuilder> builderSupplier;
/**
* Construct an instance using a {@link WrapperMessageBuilder}.
*/
public DefaultStreamMessageConverter() {
this.builder = () -> new WrapperMessageBuilder();
this.builderSupplier = () -> new WrapperMessageBuilder();
}
/**
@@ -52,7 +55,7 @@ public class DefaultStreamMessageConverter implements StreamMessageConverter {
* @param codec the codec.
*/
public DefaultStreamMessageConverter(@Nullable Codec codec) {
this.builder = () -> codec.messageBuilder();
this.builderSupplier = () -> codec.messageBuilder();
}
@Override
@@ -67,7 +70,7 @@ public class DefaultStreamMessageConverter implements StreamMessageConverter {
@Override
public com.rabbitmq.stream.Message fromMessage(Message message) throws MessageConversionException {
MessageBuilder builder = this.builder.get();
MessageBuilder builder = this.builderSupplier.get();
PropertiesBuilder propsBuilder = builder.properties();
MessageProperties mProps = message.getMessageProperties();
JavaUtils.INSTANCE