public void Update()

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;
        }