in rocketmq-client-csharp/PublishLoadBalancer.cs [71:86]
private bool Accept(List<rmq::MessageQueue> existing, rmq::MessageQueue messageQueue)
{
if (0 == existing.Count)
{
return true;
}
foreach (var item in existing)
{
if (item.Broker.Equals(messageQueue.Broker))
{
return false;
}
}
return true;
}