Add constructor that takes a MongoCollection object.
Make Get() return a Message instance instead of BsonDocument. Seperates id and payload.
Add some missing doc.
Add streams supoort to messages.