File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -40,7 +40,7 @@ public class RocketMQUtil {
4040
4141 private static final Logger log = LoggerFactory .getLogger (RocketMQUtil .class );
4242
43- private static final ClientServiceProvider provider = ClientServiceProvider .loadService ();
43+ private static final ClientServiceProvider PROVIDER = ClientServiceProvider .loadService ();
4444
4545 public static org .apache .rocketmq .client .apis .message .Message convertToClientMessage (
4646 MessageConverter messageConverter , String charset ,
@@ -72,7 +72,7 @@ public static org.apache.rocketmq.client.apis.message.Message getAndWrapMessage(
7272 if (ObjectUtils .isEmpty (keys )) {
7373 keys = headers .get (toRocketHeaderKey (RocketMQHeaders .KEYS ));
7474 }
75- messageBuilder = provider .newMessageBuilder ()
75+ messageBuilder = PROVIDER .newMessageBuilder ()
7676 .setTopic (tempArr [0 ]);
7777 if (tempArr .length > 1 ) {
7878 messageBuilder .setTag (tempArr [1 ]);
You can’t perform that action at this time.
0 commit comments