INNER CODE UNIT · Go

InitProducer

owlistic-notes/owlistic · src/backend/broker/producer.go:92

func InitProducer(cfg config.Config) error {
	broker := cfg.EventBroker

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

	var err error
	producerMutex.Lock()
	DefaultProducer, err = NewNATSProducer(broker)
	producerMutex.Unlock()

	DefaultProducer.CreateTopics("owlistic", SubjectNames)

	return err
}

View source record →