Refactored the public interface for kicking off processing
Added framework for processing a set of records