CollectProcessor0.java 435 B

123456789101112131415
  1. package collect.processor;
  2. import org.apache.camel.Exchange;
  3. import org.apache.camel.Message;
  4. import org.apache.camel.Processor;
  5. /**
  6. * Created by Zdm on 2016/7/13.
  7. */
  8. public class CollectProcessor0 implements Processor {
  9. public void process(Exchange exchange) throws Exception {
  10. Message outMessage = exchange.getOut();
  11. outMessage.setHeader(Exchange.HTTP_QUERY, "jobId=5ad5c11655d443c30155d477a6b10000");
  12. }
  13. }