serializeTypeCurrentRPC=ROCKETMQ not support pop consuming

[yuz10]

BUG REPORT

1. Please describe the issue you observed:

• What did you do (The steps to reproduce)?
  1. first, open pop with mqadmin setConsumeMode -n localhost:9876 -c DefaultCluster -t topic -g group -m POP
  2. start rocketmq pop consumer with -Drocketmq.serialize.type=ROCKETMQ

        System.setProperty(RemotingCommand.SERIALIZE_TYPE_PROPERTY, SerializeType.ROCKETMQ.name());
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group");
        consumer.setNamesrvAddr("localhost:9876");
        consumer.setClientRebalance(false);
        consumer.subscribe("topic", "*");
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
        consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
            System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        });
        consumer.setClientRebalance(false);
        consumer.start();
        System.out.printf("Consumer Started.%n");

• What is expected to see?
  no error
• What did you see instead?
  In /root/logs/rocketmqlogs/rockemq_client.log, error like "CODE: 3 DESC: request type 3442 not supported"

2. Please tell us about your environment:

3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
   in rocketmq serialize type, the request code is a short, the requestCode "POP_MESSAGE=200050" is larger than short max 65535.
   

[github-actions]

This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.

[github-actions]

This issue was closed because it has been inactive for 3 days since being marked as stale.