HttpProcessor.java

@ApplicationScoped
public class MyCloudEventProcessor {



  @Incoming("from-http")
  @Outgoing("to-http")
  public HttpMessage<CloudEventMessage>  process(CloudEventMessage<String> message) {


    return HttpMessage.HttpMessageBuilder.<CloudEventMessage>create()
      .withMethod("PUT")
      .withPayload(message)
      .withHeader("Content-Type", "application/cloudevents+json")
      .build();
  }
}