ExecutionService now registers for message updates. Once all messages have been read and job is completed, job is removed.
