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);
									System.out.println("BEAN - " + bean);
									exchange.getIn().setBody(POJOHelper.serialize(bean));
								}
							})
							.to("rabbitmq:localhost:5672/parsed_errors?queue=parsed_errors_queue&username=guest&password=guest&autoDelete=false&routingKey=parsed_errors_queue");
				}
			});
			context.start();