Update ProducerImpl.java

Replaced "replaceAll()" to "replace()"
apache · Apr 5, 2023 · dba92da · dba92da
1 parent 4eb819f
commit dba92da
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...e-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java b/...e-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java
@@ -146,7 +146,7 @@ public void reply(final CloudEvent cloudEvent, final SendCallback sendCallback)
 
     private Message supplySysProp(Message msg, CloudEvent cloudEvent) {
         for (String sysPropKey : MessageConst.STRING_HASH_SET) {
-            String ceKey = sysPropKey.toLowerCase().replaceAll("_", Constants.MESSAGE_PROP_SEPARATOR);
+            String ceKey = sysPropKey.toLowerCase().replace("_", Constants.MESSAGE_PROP_SEPARATOR);
             if (cloudEvent.getExtension(ceKey) != null && StringUtils.isNotEmpty(Objects.requireNonNull(cloudEvent.getExtension(ceKey)).toString())) {
                 MessageAccessor.putProperty(msg, sysPropKey, Objects.requireNonNull(cloudEvent.getExtension(ceKey)).toString());
                 msg.getProperties().remove(ceKey);
@@ -163,7 +163,7 @@ public void onSuccess(org.apache.rocketmq.common.message.Message message) {
                 for (String sysPropKey : MessageConst.STRING_HASH_SET) {
                     if (StringUtils.isNotEmpty(message.getProperty(sysPropKey))) {
                         String prop = message.getProperty(sysPropKey);
-                        String tmpPropKey = sysPropKey.toLowerCase().replaceAll("_", Constants.MESSAGE_PROP_SEPARATOR);
+                        String tmpPropKey = sysPropKey.toLowerCase().replace("_", Constants.MESSAGE_PROP_SEPARATOR);
                         MessageAccessor.putProperty(message, tmpPropKey, prop);
                         message.getProperties().remove(sysPropKey);
                     }