code: func (em *Emitter) Publish(ctx context.Context, message interface{}, tags query.Tagged) error {
  	if em == nil || em.pubsubServer == nil {
  		return nil
  	}
  	return em.pubsubServer.PublishWithTags(ctx, message, tags)
  }
docs: // Publish tells the emitter to publish with the given message and tags