public static void main(String[] args) throws InterruptedException, MQClientException {
/*
* Instantiate with specified consumer group name.
@@ -737,4 +737,4 @@
throw new RemotingTimeoutException(info);
}
}
- }
\ No newline at end of file
+ }
\ No newline at end of file
diff --git a/2020/07/05/聊一下-RocketMQ-的-NameServer-源码/index.html b/2020/07/05/聊一下-RocketMQ-的-NameServer-源码/index.html
index ff7390496f..f29b663824 100644
--- a/2020/07/05/聊一下-RocketMQ-的-NameServer-源码/index.html
+++ b/2020/07/05/聊一下-RocketMQ-的-NameServer-源码/index.html
@@ -1,4 +1,4 @@
-聊一下 RocketMQ 的 NameServer 源码 | Nicksxs's Blog
publicstaticvoidmain(String[] args){main0(args);}
@@ -563,4 +563,4 @@
response.setRemark("No topic route info in name server for the topic: "+ requestHeader.getTopic()+FAQUrl.suggestTodo(FAQUrl.APPLY_TOPIC_URL));return response;
- }