Method publishAnnounce

server/server.go:311–315

publishAnnounce sends a message out over MessageBus, logging any error

(subject string, msg *proxy.Announcement)

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

// publishEvent sends a message out over MessageBus, logging any error
func (s *Server) publishEvent(subject string, msg ari.Event) {