timetable-mgr/src/vstp/subscribe.go

package vstp

import (
	"git.fjla.uk/owlboard/mq-client/log"
	"git.fjla.uk/owlboard/mq-client/messaging"
	"github.com/go-stomp/stomp/v3"
)

func Subscribe() {
	sub, err := messaging.Client.Subscribe("/topic/VSTP_ALL", stomp.AckAuto)
	if err != nil {
		log.Msg.Fatal("Unable to start subscription: " + err.Error())
	}
	log.Msg.Info("Subscription to VSTP topic successful, listening")

	go func() {
		log.Msg.Debug("GOROUTINE: VSTP Message Handler Started")
		defer log.Msg.Warn("GOROUTINE: VSTP Message Handler Stopped")
		for {
			msg := <-sub.C
			if msg.Err != nil {
				log.Msg.Error("\nSTOMP Message Error: " + msg.Err.Error())
			} else {
				log.Msg.Debug("\nSTOMP Message Received")
				saveToFile(string(msg.Body), "msgBody")
				handle(msg)
			}
		}
	}()

	select {}
}