PublishTool.java 文件源码

java
阅读 22 收藏 0 点赞 0 评论 0

项目:tracing-framework 作者:
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);
    }
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号