code: func (p *Plugin) NewWatcher(name string) messaging.ProtoWatcher {
  	return p.NewProtoConnection(name)
  }
docs: // NewWatcher creates a watcher that allows to start/stop consuming of messaging published to given topics.