Method Close

broker.go:374–380

Close closes the broker resources

()

// Close closes the broker resources
func (b *Broker) Close() error {
	b.lock.Lock()
	defer b.lock.Unlock()

	b.connErr = nil
	return b.closeLocked()
}

// maybeCloseLocked closes on transport errors and reports whether a close was performed.
// NOTE: caller must hold b.lock.