(rocketmq) branch develop updated: [ISSUE #8182] Modify variable names to enhance readability #8182

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new b58eefc1a6 [ISSUE #8182] Modify variable names to enhance readability 
#8182
b58eefc1a6 is described below

commit b58eefc1a6c272726f17c16b4bb0c2a2666578fa
Author: Stephanie0002 <55239858+stephanie0...@users.noreply.github.com>
AuthorDate: Thu May 23 20:15:20 2024 +0800

    [ISSUE #8182] Modify variable names to enhance readability #8182
---
 .../main/java/org/apache/rocketmq/example/operation/Consumer.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java 
b/example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java
index 90f2e133a1..378a976997 100644
--- a/example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java
@@ -36,15 +36,15 @@ public class Consumer {
     public static void main(String[] args) throws MQClientException {
         CommandLine commandLine = buildCommandline(args);
         if (commandLine != null) {
-            String group = commandLine.getOptionValue('g');
+            String subGroup = commandLine.getOptionValue('g');
             String topic = commandLine.getOptionValue('t');
-            String subscription = commandLine.getOptionValue('s');
+            String subExpression = commandLine.getOptionValue('s');
             final String returnFailedHalf = commandLine.getOptionValue('f');
 
-            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(group);
+            DefaultMQPushConsumer consumer = new 
DefaultMQPushConsumer(subGroup);
             
consumer.setInstanceName(Long.toString(System.currentTimeMillis()));
 
-            consumer.subscribe(topic, subscription);
+            consumer.subscribe(topic, subExpression);
 
             consumer.registerMessageListener(new MessageListenerConcurrently() 
{
                 AtomicLong consumeTimes = new AtomicLong(0);