code: func NewMessageStore(pol common.MessageReplacingPolicy, trigger invalidationTrigger) MessageStore {
  	return newMsgStore(pol, trigger)
  }
docs: // NewMessageStore returns a new MessageStore with the message replacing
  // policy and invalidation trigger passed.