Added exception handling to part of the MultiProcessConsumer.