func (mexset *messageExchangeSet) removeExchange(msgID uint32) {
	if mexset.log.Enabled(LogLevelDebug) {
		mexset.log.Debugf("Removing %s message exchange %d", mexset.name, msgID)
	}

	mexset.Lock()
	found, expired := mexset.deleteExchange(msgID)
	mexset.Unlock()

	if !found && !expired {
		mexset.log.WithFields(
			LogField{"msgID", msgID},
		).Error("Tried to remove exchange multiple times")
		return
	}

	// If the message exchange was found, then we perform clean up actions.
	// These clean up actions can only be run once per exchange.
	mexset.onRemoved()
}
func (mexset *messageExchangeSet) removeExchange(msgID uint32) {
	if mexset.log.Enabled(LogLevelDebug) {
		mexset.log.Debugf("Removing %s message exchange %d", mexset.name, msgID)
	}

	mexset.Lock()
	found, expired := mexset.deleteExchange(msgID)
	mexset.Unlock()

	if !found && !expired {
		mexset.log.WithFields(
			LogField{"msgID", msgID},
		).Error("Tried to remove exchange multiple times")
		return
	}

	
	
	mexset.onRemoved()
}
func ( mexset * messageExchangeSet ) removeExchange ( msgID uint32 ) { if mexset . log . Enabled ( LogLevelDebug ) { mexset . log . Debugf ( " " , mexset . name , msgID ) } mexset . Lock ( ) found , expired := mexset . deleteExchange ( msgID ) mexset . Unlock ( ) if ! found && ! expired { mexset . log . WithFields ( LogField { " " , msgID } , ) . Error ( " " ) return } // If the message exchange was found, then we perform clean up actions. // These clean up actions can only be run once per exchange. mexset . onRemoved ( ) }
// removeExchange removes a message exchange from the set, if it exists.
removeExchange removes a message exchange from the set if it exists .