Skip to content

Commit a2f11d3

Browse files
3424672656RongtongJin
authored andcommitted
[ISSUE #9223] Pop consumer example add the default NamesrvAddr (#9224)
1 parent c0f7766 commit a2f11d3

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

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

Lines changed: 4 additions & 0 deletions
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)