INNER CODE UNIT · Go

CloseProducer

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

func CloseProducer() {
	producerMutex.Lock()
	defer producerMutex.Unlock()

	if DefaultProducer != nil {
		DefaultProducer.Close()
		DefaultProducer = nil
	}
}

// IsProducerAvailable returns whether the default producer is available
func IsProducerAvailable() bool {
	producerMutex.RLock()
	defer producerMutex.RUnlock()

	if DefaultProducer == nil {
		return false
	}

View source record →