Added exception handling for message consumer