[issue apache#1654] fix NullPointerException of broadcastEventListener

abcMH1966 · Oct 21, 2022 · f458ce8 · f458ce8
1 parent 6fb6ab6
commit f458ce8
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java b/...main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
@@ -194,9 +194,8 @@ public void consume(CloudEvent event, AsyncConsumeContext context) {
                         .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);