public void SendPublishEvent()

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

• 19 lines of code
• 2 McCabe index (conditional complexity)

  public void SendPublishEvent(String channelName, boolean useTextEvent) throws Exception {

    CustomMessage message = new CustomMessage("Hello world from Java client library");

    LOGGER.log(Level.INFO, "Building CloudEvent");

    ObjectMapper objectMapper = new ObjectMapper();
    CloudEvent event = new CloudEventBuilder()
        .withId(UUID.randomUUID().toString())
        .withSource(URI.create("//provider/source"))
        .withType("provider.v1.event")
        .withTime(OffsetDateTime.now())
        .withExtension("extsourcelang", "java")
        .withData("application/json",
            JsonCloudEventData.wrap(objectMapper.valueToTree(message)))
        .build();

    if (useTextEvent) {
      SendEventUsingTextFormat(channelName, event);
    } else {
      SendEventUsingProtoFormat(channelName, event);
    }
  }