I am trying to write a route which is triggered by a JMS message on a queue. It then polls the database using JPA endpoint, converts the row to an entity. Then I want to do some processing on that entity and finally persist it back to the db.

Following is my route

from("localjms:queue:Test.Queue")

.from("jpa:com.mycompany.servicebus.services.entities.test.TestEntity?consumer.query=select t from com.mycompany.servicebus.services.entities.test.TestEntity t where t.id = 1&consumeDelete=false")

.process(new Processor() {

@Override

public void process(Exchange exchng) throws Exception {

TestEntity entity = exchng.getIn().getBody(TestEntity.class);

if(entity != null){

entity.doSomeStuff();

}

}

})

.to("jpa:com.mycompany.servicebus.services.entities.test.TestEntity")

.end();

Now the issue that I am facing is that the route constantly polls the db, reads the row and does the aforementioned processing. But I want it to be once off. i.e. when a message is sent to the inbound JMS queue. Can you think of a way by which I could achieve this?

I could inject the entity manager and use plain java code. But I would prefer to use DSL.

Any suggestions? Please advise.

Regards,
Mohit