Fixed Consumer to remove the events from the queue properly.