public static void main(String[] args) throws InterruptedException {
// Configure console logging
BasicConfigurator.configure();
String topic = "publishing_to_topic";
if (args.length > 0) {
topic = args[0];
}
System.out.println("Subscribing to topic " + topic);
// Subscribe to the topic
PubSub.subscribe(topic, new SubscribeToolSubscriber());
// Wait for the client to be interrupted
PubSub.client().join();
}
SubscribeTool.java 文件源码
java
阅读 71
收藏 0
点赞 0
评论 0
项目:tracing-framework
作者:
评论列表
文章目录