INNER CODE UNIT · Go

NewNatsConsumer

owlistic-notes/owlistic · src/backend/broker/consumer.go:42

func NewNatsConsumer(natsServerAddress string, topics []string, groupID string) (Consumer, error) {
	if natsServerAddress == "" {
		natsServerAddress = nats.DefaultURL
	}

	log.Printf("Connecting to NATS server at: %s", natsServerAddress)

	nc, err := nats.Connect(
		natsServerAddress,
		nats.Name("owlistic-producer-" + groupID ),
		nats.MaxReconnects(5),
	)
	if err != nil {
		log.Printf("Failed to connect to NATS: %v", err)
		return nil, err
	}

	js, err := nc.JetStream()

View source record →