diff --git a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java index db861305ae..fab7166f19 100644 --- a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java +++ b/eventmesh-storage-plugin/eventmesh-storage-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); }