in rocketmq-client-csharp/PublishLoadBalancer.cs [48:66]
public void Update(TopicRouteData route)
{
List<rmq::MessageQueue> partitions = new List<rmq::MessageQueue>();
foreach (var partition in route.MessageQueues)
{
if (rmq::Permission.Unspecified == partition.Permission)
{
continue;
}
if (rmq::Permission.Read == partition.Permission)
{
continue;
}
partitions.Add(partition);
}
partitions.Sort();
this._messageQueues = partitions;
}