@@ -0,0 +1,502 @@
+package de.openknowledge.jaxrs.reactive.test;%0A%0Aimport java.io.IOException;%0A%0Aimport com.fasterxml.jackson.databind.ObjectMapper;%0A%0Aimport de.openknowledge.reactive.AbstractSimpleProcessor;%0A%0Apublic class CustomerWriter extends AbstractSimpleProcessor%3CCustomer, String%3E %7B%0A%0A  private ObjectMapper mapper = new ObjectMapper();%0A  @Override%0A  public void onNext(Customer customer) %7B%0A    %0A    try %7B%0A      publish(mapper.writeValueAsString(customer));%0A    %7D catch (IOException e) %7B%0A      onError(e);%0A    %7D%0A  %7D%0A%7D%0A

Add CustomerWriter