public void watch()

in mode/cluster/repository/nacos/src/main/java/org/apache/shardingsphere/mode/repository/cluster/nacos/NacosRepository.java [139:155]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    public void watch(final String key, final DataChangedEventListener listener) {
        try {
            for (ServiceMetaData each : serviceController.getAllServices()) {
                NamingEventListener eventListener = each.getListener();
                if (null != eventListener) {
                    eventListener.put(key, listener);
                    return;
                }
                eventListener = new NamingEventListener();
                eventListener.put(key, listener);
                each.setListener(eventListener);
                client.subscribe(each.getServiceName(), eventListener);
            }
        } catch (final NacosException ex) {
            throw new ClusterRepositoryPersistException(ex);
        }
    }