You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/10/22 12:08:00 UTC
[incubator-eventmesh] branch master updated: [issue #1654] fix NullPointerException of broadcastEventListener
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng 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 f458ce8d [issue #1654] fix NullPointerException of broadcastEventListener
new 8d71a1bf Merge pull request #1734 from abcMH1966/master
f458ce8d is described below
commit f458ce8d03b674b9ebc316c54915859da0f86311
Author: abcMH1966 <25...@qq.com>
AuthorDate: Fri Oct 21 16:49:12 2022 +0800
[issue #1654] fix NullPointerException of broadcastEventListener
---
.../runtime/core/protocol/http/consumer/EventMeshConsumer.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
index 0b600c5e..3593a73f 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
@@ -194,9 +194,8 @@ public class EventMeshConsumer {
.build();
String topic = event.getSubject();
- String bizSeqNo =
- event.getExtension(Constants.PROPERTY_MESSAGE_SEARCH_KEYS).toString();
- String uniqueId = event.getExtension(Constants.RMB_UNIQ_ID).toString();
+ String bizSeqNo = event.getExtension(ProtocolKey.ClientInstanceKey.BIZSEQNO).toString();
+ String uniqueId = event.getExtension(ProtocolKey.ClientInstanceKey.UNIQUEID).toString();
if (messageLogger.isDebugEnabled()) {
messageLogger.debug("message|mq2eventMesh|topic={}|msg={}", topic, event);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org