Abstract Camel Processor

AbstractCamelProcessor.java

public abstract class CamelProcessor<T> implements Processor
{
    protected void process(Exchange exchange, ResultMapper<T> mapper) throws Exception
    {
        try
        {
            ArrayList<T> payloads = new ArrayList<T>();
            ArrayList<HashMap<String, Object>> data = exchange.getIn().getBody(ArrayList.class);
            if (data != null)
            {
                for (HashMap<String, Object> obj : data)
                {
                    payloads.add(mapper.valueOf(obj));
                }
            }
            exchange.getIn().setBody(payloads);
        }
        catch (Exception e)
        {
            // TODO common error handling
            e.printStackTrace();
        }
    }

}