Method publishEvent

server/server.go:318–322

publishEvent sends a message out over MessageBus, logging any error

(subject string, msg ari.Event)

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

// newRequestHandler returns a context-wrapped Handler to handle requests
func (s *Server) newRequestHandler(ctx context.Context) func(subject string, reply string, req *proxy.Request) {