in serverless-workflow-examples/serverless-workflow-loanbroker-showcase/loanbroker-ui/src/main/java/org/acme/loanbroker/AppResource.java [68:76]
public Response consumeQuotesEvent(CloudEvent cloudEvent) {
LOGGER.info("Received Cloud Event {}", cloudEvent);
if (cloudEvent == null || cloudEvent.getData() == null) {
return Response.status(400).entity("{ \"message\": \"CloudEvent without data\" }").build();
}
final QuotesResponse quotes = this.quotesRepository.add(cloudEvent);
bus.publish("new-quote", quotes);
return Response.ok().build();
}