Skip to content

Commit ad60f33

Browse files
authored
[ISSUE #9223] Pop consumer example add the default NamesrvAddr (#9224)
1 parent 5c34a59 commit ad60f33

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

example/src/main/java/org/apache/rocketmq/example/simple/PopConsumer.java

+4
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
public class PopConsumer {
3333
public static final String TOPIC = "TopicTest";
3434
public static final String CONSUMER_GROUP = "CID_JODIE_1";
35+
public static final String NAMESRV_ADDR = "127.0.0.1:9876";
3536
public static void main(String[] args) throws Exception {
3637
switchPop();
3738
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(CONSUMER_GROUP);
@@ -44,12 +45,15 @@ public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeCo
4445
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
4546
}
4647
});
48+
// Uncomment the following line while debugging, namesrvAddr should be set to your local address
49+
// consumer.setNamesrvAddr(NAMESRV_ADDR);
4750
consumer.setClientRebalance(false);
4851
consumer.start();
4952
System.out.printf("Consumer Started.%n");
5053
}
5154
private static void switchPop() throws Exception {
5255
DefaultMQAdminExt mqAdminExt = new DefaultMQAdminExt();
56+
// mqAdminExt.setNamesrvAddr(NAMESRV_ADDR);
5357
mqAdminExt.start();
5458
List<BrokerData> brokerDatas = mqAdminExt.examineTopicRouteInfo(TOPIC).getBrokerDatas();
5559
for (BrokerData brokerData : brokerDatas) {

0 commit comments

Comments
 (0)