INNER CODE UNIT · Go

CloseAllConsumers

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

func CloseAllConsumers() {
	consumerMutex.Lock()
	defer consumerMutex.Unlock()

	for key, consumer := range consumers {
		log.Printf("Closing consumer: %s", key)
		consumer.Close()
	}

	// Clear the map
	consumers = make(map[string]*NatsConsumer)
}

View source record →