unloadPM taskQueuePartitionManager,
unloadCause unloadCause,
key := partition.Key()
e.partitionsLock.Lock()
foundTQM, ok := e.partitions[key]
if !ok || (unloadPM != nil && foundTQM != unloadPM) {
e.partitionsLock.Unlock()
return false
}
e.partitionsLock.Unlock()
foundTQM.Stop(unloadCause)
return true
}