adding the consumer which pushes the messages into mongo