in rocketmq-client-csharp/PushConsumer.cs [213:225]
private void CancelPop(rmq::Assignment assignment)
{
if (!_processQueueMap.ContainsKey(assignment))
{
return;
}
ProcessQueue processQueue;
if (_processQueueMap.Remove(assignment, out processQueue))
{
processQueue.Dropped = true;
}
}