We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8a900c0 commit caff42bCopy full SHA for caff42b
rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQUtil.java
@@ -87,11 +87,11 @@ public static org.apache.rocketmq.client.apis.message.Message getAndWrapMessage(
87
messageBuilder.setBody(payloads);
88
org.apache.rocketmq.client.apis.message.MessageBuilder builder = messageBuilder;
89
headers.forEach((key, value) ->
90
- {
91
- if (!RocketMQHeaders.SYSTEM_PROPERTY_SET.contains(key)) {
92
- builder.addProperty(key, String.valueOf(value));
93
- }
+ {
+ if (!RocketMQHeaders.SYSTEM_PROPERTY_SET.contains(key)) {
+ builder.addProperty(key, String.valueOf(value));
94
}
+ }
95
96
);
97
0 commit comments