opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #8182] Modify variable names to enhance readability #8182

Browse Source
This commit is contained in:
Stephanie0002
2024-05-23 20:15:20 +08:00
committed by GitHub
parent dcc88c65f1
commit b58eefc1a6
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java
+4 -4
View File
@@ -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);