You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mx...@apache.org on 2023/07/25 15:05:33 UTC
[eventmesh] branch master updated: [ISSUE #4267] Optimized [GrpcEventMeshCloudEventProtocolResolver] (#4279)
This is an automated email from the ASF dual-hosted git repository.
mxsm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new fe13a8571 [ISSUE #4267] Optimized [GrpcEventMeshCloudEventProtocolResolver] (#4279)
fe13a8571 is described below
commit fe13a85713f6b7cf39ccce62ac8aef40380941b6
Author: Sam V Jose <12...@users.noreply.github.com>
AuthorDate: Tue Jul 25 20:35:27 2023 +0530
[ISSUE #4267] Optimized [GrpcEventMeshCloudEventProtocolResolver] (#4279)
* [ISSUE #4269] Used switch to replace the if-else. [MeshMessageProtocolAdaptor]
* [ISSUE #4269] Used switch to replace the if-else. [MeshMessageProtocolAdaptor]
* [ISSUE #4269] Used switch to replace the if-else. [MeshMessageProtocolAdaptor]
* [ISSUE #4269] Used switch to replace the if-else. [MeshMessageProtocolAdaptor]
* [ISSUE #4267] Optimized [GrpcEventMeshCloudEventProtocolResolver]
* [ISSUE #4267] Optimized [GrpcEventMeshCloudEventProtocolResolver]
---
.../resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java b/eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java
index 99a6b92bf..a00d1852a 100644
--- a/eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java
+++ b/eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java
@@ -17,13 +17,13 @@
package org.apache.eventmesh.protocol.cloudevents.resolver.grpc;
-
import org.apache.eventmesh.common.protocol.grpc.cloudevents.CloudEvent;
import org.apache.eventmesh.common.protocol.grpc.cloudevents.CloudEventBatch;
import org.apache.eventmesh.common.protocol.grpc.common.EventMeshCloudEventWrapper;
import java.util.ArrayList;
import java.util.List;
+import java.util.Objects;
import java.util.stream.Collectors;
import io.cloudevents.core.format.EventFormat;
@@ -40,15 +40,14 @@ public class GrpcEventMeshCloudEventProtocolResolver {
private static final EventFormat eventFormat = EventFormatProvider.getInstance().resolveFormat(ProtobufFormat.PROTO_CONTENT_TYPE);
public static io.cloudevents.CloudEvent buildEvent(CloudEvent cloudEvent) {
- io.cloudevents.CloudEvent event = eventFormat.deserialize(cloudEvent.toByteArray());
- return event;
+ return Objects.requireNonNull(eventFormat).deserialize(cloudEvent.toByteArray());
}
public static List<io.cloudevents.CloudEvent> buildBatchEvents(CloudEventBatch cloudEventBatch) {
if (cloudEventBatch == null || cloudEventBatch.getEventsCount() < 1) {
return new ArrayList<>(0);
}
- return cloudEventBatch.getEventsList().stream().map(cloudEvent -> eventFormat.deserialize(cloudEvent.toByteArray()))
+ return cloudEventBatch.getEventsList().stream().map(cloudEvent -> Objects.requireNonNull(eventFormat).deserialize(cloudEvent.toByteArray()))
.collect(Collectors.toList());
}
@@ -57,7 +56,7 @@ public class GrpcEventMeshCloudEventProtocolResolver {
return new EventMeshCloudEventWrapper(null);
}
try {
- return new EventMeshCloudEventWrapper(CloudEvent.parseFrom(eventFormat.serialize(cloudEvent)));
+ return new EventMeshCloudEventWrapper(CloudEvent.parseFrom(Objects.requireNonNull(eventFormat).serialize(cloudEvent)));
} catch (InvalidProtocolBufferException e) {
log.error("Build Event Mesh CloudEvent from io.cloudevents.CloudEvent error", e);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org