in rocketmq-client-csharp/Client.cs [102:116]
protected string FilterBroker(Func<string, bool> acceptor)
{
foreach (var item in _topicRouteTable)
{
foreach (var partition in item.Value.MessageQueues)
{
string target = Utilities.TargetUrl(partition);
if (acceptor(target))
{
return target;
}
}
}
return null;
}