This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new dddfdf093 Update PushConsumerImpl.java
new 2a185c41b Merge pull request #3630 from harshithasudhakar/patch-4
dddfdf093 is described below
commit dddfdf093a74159b1ad62d8e855f739272feef8d
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Wed Apr 5 11:15:19 2023 +0530
Update PushConsumerImpl.java
Replaced "replaceAll()" with "replace()"
---
.../apache/eventmesh/storage/rocketmq/consumer/PushConsumerImpl.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/consumer/PushConsumerImpl.java
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/consumer/PushConsumerImpl.java
index 4a4e2d43c..aaf875709 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/consumer/PushConsumerImpl.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/consumer/PushConsumerImpl.java
@@ -186,7 +186,7 @@ public class PushConsumerImpl {
for (String sysPropKey : MessageConst.STRING_HASH_SET) {
if (StringUtils.isNotEmpty(msg.getProperty(sysPropKey))) {
String prop = msg.getProperty(sysPropKey);
- sysPropKey = sysPropKey.toLowerCase().replaceAll("_",
Constants.MESSAGE_PROP_SEPARATOR);
+ sysPropKey = sysPropKey.toLowerCase().replace("_",
Constants.MESSAGE_PROP_SEPARATOR);
cloudEventBuilder =
CloudEventBuilder.from(cloudEvent).withExtension(sysPropKey, prop);
}
}
@@ -257,7 +257,7 @@ public class PushConsumerImpl {
for (String sysPropKey : MessageConst.STRING_HASH_SET) {
if (StringUtils.isNotEmpty(msg.getProperty(sysPropKey))) {
String prop = msg.getProperty(sysPropKey);
- sysPropKey = sysPropKey.toLowerCase().replaceAll("_",
Constants.MESSAGE_PROP_SEPARATOR);
+ sysPropKey = sysPropKey.toLowerCase().replace("_",
Constants.MESSAGE_PROP_SEPARATOR);
cloudEventBuilder =
CloudEventBuilder.from(cloudEvent).withExtension(sysPropKey, prop);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
