private void startTimerService()

in appactive-java-client/client-channel/src/main/java/io/appactive/channel/nacos/NacosReadDataSource.java [72:94]

• 22 lines of code
• 2 McCabe index (conditional complexity)

    private void startTimerService() {
        try {
            Properties properties = new Properties();
            properties.put(PropertyKeyConst.SERVER_ADDR, serverAddr);
            properties.put(PropertyKeyConst.NAMESPACE, namespaceId);
            configService = NacosFactory.createConfigService(properties);

            configService.addListener(dataId, groupId, new Listener() {
                @Override
                public void receiveConfigInfo(String configInfo) {
                    lastModified = System.currentTimeMillis();
                    LogUtil.warn("get Nacos configInfo {}", configInfo);
                    initMemoryValue(converterInterface.convert(configInfo));
                }
                @Override
                public Executor getExecutor() {
                    return null;
                }
            });
        } catch (NacosException e) {
            LogUtil.error("get Nacos configService Exception ", e);
        }
    }