Hi, I wrote a custom processor which consumes a message from amazon sqs. When run, the processor is not getting out of the processor. In the processor, there is a read to amazon dynamodb. It keeps on consuming the same message and is stuck there. Please help.
from(sqsQueue) .unmarshal() .json(JsonLibrary.Gson, Hello.class) .process(new DatabaseEntryHandler()) .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { System.out.println("processor"); } });