Method runEventHandler

server/server.go:271–294

runEventHandler processes events which are received from ARI

(ctx context.Context)

// runEventHandler processes events which are received from ARI
func (s *Server) runEventHandler(ctx context.Context) {
	sub := s.ari.Bus().Subscribe(nil, ari.Events.All)
	defer sub.Cancel()

	for {
		s.Log.Debug("listening for events", "application", s.Application)
		select {
		case <-ctx.Done():
			return
		case e := <-sub.Events():
			s.Log.Debug("event received", "kind", e.GetType())

			// Publish event to canonical destination
			s.publishEvent(fmt.Sprintf("%sevent.%s.%s", s.MBPrefix, s.Application, s.AsteriskID), e)

			// Publish event to any associated dialogs
			for _, d := range s.dialogsForEvent(e) {
				de := e
				de.SetDialog(d)
				s.publishEvent(fmt.Sprintf("%sdialogevent.%s", s.MBPrefix, d), de)
			}
		}
	}
}

// pingHandler publishes the server's presence
func (s *Server) pingHandler() {