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 dba92da8a Update ProducerImpl.java
new c10796ce4 Merge pull request #3631 from harshithasudhakar/master
dba92da8a is described below
commit dba92da8adcb5c58c7b38e141895ea05401983fc
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Wed Apr 5 11:30:06 2023 +0530
Update ProducerImpl.java
Replaced "replaceAll()" to "replace()"
---
.../org/apache/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 db861305a..fab7166f1 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 class ProducerImpl extends AbstractProducer {
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 class ProducerImpl extends AbstractProducer {
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);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
