package crawler.processor;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;

/**
 * Created by Zdm on 2016/7/13.
 */
public class Processor2 implements Processor {
    private String key;

    public Processor2(String key) {
        this.key = key;
    }

    public void process(Exchange exchange) throws Exception {
        Message inMessage = exchange.getIn();
        Message outMessage = exchange.getOut();
        outMessage.setHeader("test_correlation_key", this.key);
        String body = inMessage.getBody(String.class);
        outMessage.setBody(body);
    }
}