[GitHub] [rocketmq] DC-Joney opened a new issue #2987: MessageQueueSelector for message queue size is error

[GitBox]

DC-Joney opened a new issue #2987:
URL: https://github.com/apache/rocketmq/issues/2987


   ### My java code
   
   ```
   
    producer.send(message, new MessageQueueSelector() {
                   @Override
                   public MessageQueue select(List<MessageQueue> mqs, Message 
msg, Object arg) {
                       System.out.println("mqs_size:" + mqs.size());
                       int index = (int) arg;
                       return mqs.get(index % mqs.size());
                   }
               }, i);
   
   ```
   
   ### Console Print
   
   ```
   mqs_size:4
   
   ```
   
   ### MQ Setting Info
   
![image](https://user-images.githubusercontent.com/16465910/121157431-25c37b00-c87c-11eb-863b-30c988086de9.png)
   
   
   ### Question
   
   Why I have set the number of the message queue to 1, but 4 is returned?
   
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org