From dba92da8adcb5c58c7b38e141895ea05401983fc Mon Sep 17 00:00:00 2001 From: Harshitha Sudhakar <111514477+harshithasudhakar@users.noreply.github.com> Date: Wed, 5 Apr 2023 11:30:06 +0530 Subject: [PATCH] Update ProducerImpl.java Replaced "replaceAll()" to "replace()" --- .../eventmesh/storage/rocketmq/producer/ProducerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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); }