Update GrpcMessageProtocolResolver.java

pmupkin · Dec 15, 2022 · 99c92ca · 99c92ca
1 parent 2ba5029
commit 99c92ca
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/.../org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcMessageProtocolResolver.java b/.../org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcMessageProtocolResolver.java
@@ -216,6 +216,10 @@ private static CloudEventBuilder builderCloudEventBuilder(RequestHeader header,
             .withExtension(ProtocolKey.PROTOCOL_VERSION, protocolVersion);
 
     }
+
+    private static String getEventExtension(CloudEvent event, String protocolKey) {
+        return Objects.requireNonNull(event.getExtension(protocolKey)).toString();
+    }
 
     private static String getEventExtension(CloudEvent event, String protocolKey, String defaultValue) {
         Object extension = event.getExtension(protocolKey);