Add basic job interface for java/scala API, add job streaming functionality
Refactor TopicAwareActor into an actor hierarchy, add ordered+prioritized interface
fix cancel mechanism, add documentation