mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java [52:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        gmt.set(confFile.lastModified());
        scheduler = new ScheduledThreadPoolExecutor(1, new ThreadFactoryImpl("ConnectConfListener"));
        scheduler.scheduleWithFixedDelay(() -> {
            try {
                if (gmt.get() == confFile.lastModified()) {
                    return;
                }
                gmt.set(confFile.lastModified());
                InputStream in = new FileInputStream(confFile.getAbsoluteFile());
                Properties properties = new Properties();
                properties.load(in);
                in.close();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java [51:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        gmt.set(confFile.lastModified());
        scheduler = new ScheduledThreadPoolExecutor(1, new ThreadFactoryImpl("ConnectConfListener"));
        scheduler.scheduleWithFixedDelay(() -> {
            try {
                if (gmt.get() == confFile.lastModified()) {
                    return;
                }
                gmt.set(confFile.lastModified());
                InputStream in = new FileInputStream(confFile.getAbsoluteFile());
                Properties properties = new Properties();
                properties.load(in);
                in.close();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -