code: func (p *Plugin) AfterInit() error {
  	if !p.Messaging.Disabled() {
  		cfg := p.Config
  		p.Cfg.LoadValue(&cfg)
  
  		if cfg.Topic != "" {
  			var err error
  			p.adapter, err = p.Messaging.NewSyncPublisher("msgsync-connection", cfg.Topic)
  			if err != nil {
  				return err
  			}
  		}
  	}
  
  	return nil
  }
docs: // AfterInit uses provided MUX connection to build new publisher.