This is an automated email from the ASF dual-hosted git repository.
qingshanpeng 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 a94404ff3 Update CloudEventUtils.java
new c620c33bf Merge pull request #3860 from harshithasudhakar/patch-31
a94404ff3 is described below
commit a94404ff318f8528bc953f588d16bebd27f25b92
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Wed May 3 01:04:44 2023 +0530
Update CloudEventUtils.java
Replaced `replaceAll()` with `replace()` at line 88
Removed `e.printStackTrace()` at line 128
---
.../org/apache/eventmesh/storage/rocketmq/utils/CloudEventUtils.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/CloudEventUtils.java
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/CloudEventUtils.java
index cb1305451..aaf3b6ce7 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/CloudEventUtils.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/CloudEventUtils.java
@@ -85,7 +85,7 @@ public class CloudEventUtils {
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);
}
@@ -125,7 +125,6 @@ public class CloudEventUtils {
message.getProperties().forEach((k, v) ->
MessageAccessor.putProperty(rmqMessageExt, k, v));
} catch (Exception e) {
log.error("Error with msgConvertExt", e);
- e.printStackTrace();
}
return rmqMessageExt;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
