in serverless-workflow-examples/serverless-workflow-qas-service-showcase/query-service/src/main/java/org/acme/QueryServiceResource.java [91:104]
public String generateCloudEvent(String processInstanceId, String queryResponse) {
try {
return objectMapper.writeValueAsString(CloudEventBuilder.v1()
.withId(UUID.randomUUID().toString())
.withSource(URI.create("query-service"))
.withType("query_response_events")
.withTime(OffsetDateTime.now())
.withExtension("kogitoprocrefid", processInstanceId)
.withData(JsonCloudEventData.wrap(objectMapper.createObjectNode().put("answer", queryResponse)))
.build());
} catch (JsonProcessingException e) {
throw new IllegalArgumentException(e);
}
}