INNER CODE UNIT · Go

InitConsumer

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

func InitConsumer(cfg config.Config, topics []string, groupID string) (Consumer, error) {
	// Get broker from config or environment
	broker := cfg.EventBroker

	// Allow override from environment
	if envBroker := os.Getenv("BROKER_ADDRESS"); envBroker != "" {
		broker = envBroker
	}

	consumer, err := NewNatsConsumer(broker, topics, groupID)
	if err != nil {
		return nil, err
	}

	return consumer, nil
}

// GetMessageChannel implements the Consumer interface

View source record →