ResultSet Processor

ResultSetProcessor.java

public class ResultSeProcessor extends CamelProcessor<MyJPAEntity>
{
    public void process(Exchange exchange) throws Exception
    {
        process(exchange, getRowMapper());
    }

    private static ResultMapper<MyJPAEntity> getRowMapper()
    {
        ResultMapper<MyJPAEntity> mapper = new ResultMapper<MyJPAEntity>()
        {
            public MyJPAEntityvalueOf(HashMap<String, Object> data)
            {
                MyJPAEntity txn = new MyJPAEntity();
                // from resultset set the values to jpa entity and return it 
                //txn.setXXX((String)data.get("xxx"))
                return txn ;
            }
        };
        return mapper;
    }
}