code: func (s *Server) Publish(ctx context.Context, msg interface{}) error {
  	return s.PublishWithTags(ctx, msg, query.TagMap(make(map[string]interface{})))
  }
docs: // Publish publishes the given message. An error will be returned to the caller
  // if the context is canceled.