package come.mycompany.rabbitmq.sample;

import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

import com.sandos.idal.commons.model.ErrorBean;

public class RabbitCamelRoute {
	public static void main(String[] args) throws Exception {
		CamelContext context = new DefaultCamelContext();
		context.getProperties().put(Exchange.LOG_DEBUG_BODY_MAX_CHARS, "5000");
		context.getTypeConverterRegistry().addTypeConverters(new ErrorBeanConverter());
		try {
			context.addRoutes(new RouteBuilder() {
				@Override
				public void configure() throws Exception {
					from("rabbitmq://localhost:5672/errors?queue=errors_queue&username=guest&password=guest&autoDelete=false&routingKey=errors_queue")
							.process(new Processor() {
								@Override
								public void process(Exchange exchange) throws Exception {
									ErrorBean bean = exchange.getIn().getBody(ErrorBean.class);
									exchange.getOut().setBody(POJOHelper.serialize(bean));
								}
							})
//							.to("stream:out");
							.to("rabbitmq://localhost:5672/parsed_errors?routingKey=parsed_errors_queue&username=guest&password=guest");
//							.to("rabbitmq://localhost:5672/?exchange=errors&username=guest&password=guest&routingKey=errors_queue");
//					 .to("rabbitmq://localhost:5672/parsed_errors?queue=parsed_errors_queue&username=guest&password=guest&autoDelete=false&routingKey=parsed_errors_queue");
				}
			});
			context.start();
			Thread.sleep(20000);
		} finally {
			context.stop();
		}
	}

}