private PublishEventsRequest GetPublishEventsRequestWithProtoFormat()

in publish-events/channel/client-libraries/java/src/main/java/com/google/cloud/eventarc/publishing/example/PublishEventsExample.java [69:84]

• 12 lines of code
• 1 McCabe index (conditional complexity)

  private PublishEventsRequest GetPublishEventsRequestWithProtoFormat(String channelName, CloudEvent event) throws Exception {

    byte[] serializedEvent = EventFormatProvider.getInstance()
        .resolveFormat(ProtobufFormat.PROTO_CONTENT_TYPE)
        .serialize(event);

    io.cloudevents.v1.proto.CloudEvent protoEvent = io.cloudevents.v1.proto.CloudEvent.parseFrom(serializedEvent);
    Any wrappedEvent = Any.pack(protoEvent);

    PublishEventsRequest request = PublishEventsRequest.newBuilder()
        .setChannel(channelName)
        .addEvents(wrappedEvent)
        .build();

    return request;
  }