code: func (p *Plugin) NewSyncPublisher(connectionName string, topic string) (messaging.ProtoPublisher, error) {
  	return p.NewProtoConnection(connectionName).NewSyncPublisher(topic)
  }
docs: // NewSyncPublisher creates a publisher that allows to publish messages using synchronous API. The publisher creates
  // new proto connection on multiplexer with default partitioner.