added ability to configure observers
instatiated an observer per worker thread and added a close method to observers