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 23:17:28 UTC
[incubator-eventmesh] branch master updated: Update BatchPublishMessageProcessor.java
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 134a39f5 Update BatchPublishMessageProcessor.java
new c27ac9a9 Merge pull request #1757 from rrpari/patch-1
134a39f5 is described below
commit 134a39f5c49b6301aa4fa1cf00a63c6b7dc73d81
Author: Pari Rajarathinam <74...@users.noreply.github.com>
AuthorDate: Sat Oct 22 22:03:11 2022 +0530
Update BatchPublishMessageProcessor.java
Adding NPE Check
Fixes #1698
---
.../core/protocol/grpc/processor/BatchPublishMessageProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java
index 910a7149..a91627e0 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java
@@ -98,7 +98,7 @@ public class BatchPublishMessageProcessor {
for (CloudEvent event : cloudEvents) {
String seqNum = event.getId();
- String uniqueId = event.getExtension(ProtocolKey.UNIQUE_ID).toString();
+ String uniqueId = (event.getExtension(ProtocolKey.UNIQUE_ID) == null ) ? "" : event.getExtension(ProtocolKey.UNIQUE_ID).toString();
ProducerManager producerManager = eventMeshGrpcServer.getProducerManager();
EventMeshProducer eventMeshProducer = producerManager.getEventMeshProducer(producerGroup);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org