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("Publishing to topic " + topic);
while (!Thread.currentThread().isInterrupted()) {
String s = RandomStringUtils.randomAlphanumeric(10);
PubSub.publish(topic, s);
Thread.sleep(1000);
}
}
PublishTool.java 文件源码
java
阅读 23
收藏 0
点赞 0
评论 0
项目:tracing-framework
作者:
评论列表
文章目录