Method publish

server/server.go:304–308

publish sends a message out over MessageBus, logging any error

(subject string, msg *proxy.Response)

// publish sends a message out over MessageBus, logging any error
func (s *Server) publish(subject string, msg *proxy.Response) {
	if err := s.mbus.PublishResponse(subject, msg); err != nil {
		s.Log.Warn("failed to publish MessageBus message", "subject", subject, "data", msg, "error", err)
	}
}

// publishAnnounce sends a message out over MessageBus, logging any error
func (s *Server) publishAnnounce(subject string, msg *proxy.Announcement) {