Redelivery processor

RedeliveryProcessor.java

public class RedeliveryProcessor implements Processor {
	
	private static final int MAX_REDELIVERIES = 5;
	
	@Override
	public void process(Exchange exchange) throws Exception {
		final int redeliveryCount = exchange.getIn().getHeader(ServiceConstants.REDELIVERY_COUNT_HEADER_NAME, Integer.class).intValue();
		
		if (redeliveryCount <= MAX_REDELIVERIES) {
			exchange.getIn().setHeader(ServiceConstants.REDELIVERY_COUNT_HEADER_NAME, redeliveryCount + 1);
		} else {
			exchange.setProperty(Exchange.ROUTE_STOP, Boolean.TRUE);
		}
	}

}