This is an automated email from the ASF dual-hosted git repository.
mytang0 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new ecfd2e99a Added fix for issue apache#3087
new 2535908ad Merge pull request #3177 from sanskar-thakur/fix-3087
ecfd2e99a is described below
commit ecfd2e99ad936fb377bd3a70cf206f73e01274bc
Author: Zaar <[email protected]>
AuthorDate: Thu Feb 16 22:52:54 2023 +0530
Added fix for issue apache#3087
---
.../org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
index 47ac04fc7..7f868eddc 100644
---
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
+++
b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
@@ -147,7 +147,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);
- if (cloudEvent.getExtension(ceKey) != null &&
StringUtils.isNotEmpty(cloudEvent.getExtension(ceKey).toString())) {
+ 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);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
