test_class.declarator: zkServer
test_class.modifier: private
test_class.original_string: private TestingServer zkServer;
test_class.type: TestingServer
test_class.var_name: zkServer
test_class.declarator: curatorClient
test_class.modifier: private
test_class.original_string: private CuratorZookeeperClient curatorClient;
test_class.type: CuratorZookeeperClient
test_class.var_name: curatorClient
test_class.declarator: client = null
test_class.original_string: CuratorFramework client = null;
test_class.type: CuratorFramework
test_class.var_name: client
test_class.file: dubbo-remoting/dubbo-remoting-zookeeper/src/test/java/org/apache/dubbo/remoting/zookeeper/curator/CuratorZookeeperClientTest.java
test_class.identifier: CuratorZookeeperClientTest
test_case.body: @Test
      public void testCreateContent4Persistent() {
          String path = "/curatorTest4CrContent/content.data";
          String content = "createContentTest";
          curatorClient.delete(path);
          assertThat(curatorClient.checkExists(path), is(false));
          assertNull(curatorClient.getContent(path));
  
          curatorClient.create(path, content, false);
          assertThat(curatorClient.checkExists(path), is(true));
          assertEquals(curatorClient.getContent(path), content);
      }
test_case.class_method_signature: CuratorZookeeperClientTest.testCreateContent4Persistent()
test_case.full_signature: @Test public void testCreateContent4Persistent()
test_case.identifier: testCreateContent4Persistent
test_case.invocations: delete assertThat checkExists is assertNull getContent create assertThat checkExists is assertEquals getContent
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCreateContent4Persistent()
focal_class.declarator: logger = LoggerFactory.getLogger(CuratorZookeeperClient.class)
focal_class.modifier: protected static final
focal_class.original_string: protected static final Logger logger = LoggerFactory.getLogger(CuratorZookeeperClient.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: ZK_SESSION_EXPIRE_KEY = "zk.session.expire"
focal_class.modifier: private static final
focal_class.original_string: private static final String ZK_SESSION_EXPIRE_KEY = "zk.session.expire";
focal_class.type: String
focal_class.var_name: ZK_SESSION_EXPIRE_KEY
focal_class.declarator: CHARSET = Charset.forName("UTF-8")
focal_class.modifier: static final
focal_class.original_string: static final Charset CHARSET = Charset.forName("UTF-8");
focal_class.type: Charset
focal_class.var_name: CHARSET
focal_class.declarator: client
focal_class.modifier: private final
focal_class.original_string: private final CuratorFramework client;
focal_class.type: CuratorFramework
focal_class.var_name: client
focal_class.declarator: treeCacheMap = new ConcurrentHashMap<>()
focal_class.modifier: private
focal_class.original_string: private Map<String, TreeCache> treeCacheMap = new ConcurrentHashMap<>();
focal_class.type: Map<String, TreeCache>
focal_class.var_name: treeCacheMap
focal_class.file: dubbo-remoting/dubbo-remoting-zookeeper/src/main/java/org/apache/dubbo/remoting/zookeeper/curator/CuratorZookeeperClient.java
focal_class.identifier: CuratorZookeeperClient
focal_class.class_method_signature: CuratorZookeeperClient.CuratorZookeeperClient(URL url)
focal_class.full_signature: public  CuratorZookeeperClient(URL url)
focal_class.identifier: CuratorZookeeperClient
focal_class.modifiers: public
focal_class.parameters: (URL url)
focal_class.signature:  CuratorZookeeperClient(URL url)
focal_class.class_method_signature: CuratorZookeeperClient.createPersistent(String path)
focal_class.full_signature: @Override public void createPersistent(String path)
focal_class.identifier: createPersistent
focal_class.modifiers: @Override public
focal_class.parameters: (String path)
focal_class.return: void
focal_class.signature: void createPersistent(String path)
focal_class.class_method_signature: CuratorZookeeperClient.createEphemeral(String path)
focal_class.full_signature: @Override public void createEphemeral(String path)
focal_class.identifier: createEphemeral
focal_class.modifiers: @Override public
focal_class.parameters: (String path)
focal_class.return: void
focal_class.signature: void createEphemeral(String path)
focal_class.class_method_signature: CuratorZookeeperClient.createPersistent(String path, String data)
focal_class.full_signature: @Override protected void createPersistent(String path, String data)
focal_class.identifier: createPersistent
focal_class.modifiers: @Override protected
focal_class.parameters: (String path, String data)
focal_class.return: void
focal_class.signature: void createPersistent(String path, String data)
focal_class.class_method_signature: CuratorZookeeperClient.createEphemeral(String path, String data)
focal_class.full_signature: @Override protected void createEphemeral(String path, String data)
focal_class.identifier: createEphemeral
focal_class.modifiers: @Override protected
focal_class.parameters: (String path, String data)
focal_class.return: void
focal_class.signature: void createEphemeral(String path, String data)
focal_class.class_method_signature: CuratorZookeeperClient.deletePath(String path)
focal_class.full_signature: @Override protected void deletePath(String path)
focal_class.identifier: deletePath
focal_class.modifiers: @Override protected
focal_class.parameters: (String path)
focal_class.return: void
focal_class.signature: void deletePath(String path)
focal_class.class_method_signature: CuratorZookeeperClient.getChildren(String path)
focal_class.full_signature: @Override public List<String> getChildren(String path)
focal_class.identifier: getChildren
focal_class.modifiers: @Override public
focal_class.parameters: (String path)
focal_class.return: List<String>
focal_class.signature: List<String> getChildren(String path)
focal_class.class_method_signature: CuratorZookeeperClient.checkExists(String path)
focal_class.full_signature: @Override public boolean checkExists(String path)
focal_class.identifier: checkExists
focal_class.modifiers: @Override public
focal_class.parameters: (String path)
focal_class.return: boolean
focal_class.signature: boolean checkExists(String path)
focal_class.class_method_signature: CuratorZookeeperClient.isConnected()
focal_class.full_signature: @Override public boolean isConnected()
focal_class.identifier: isConnected
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isConnected()
focal_class.class_method_signature: CuratorZookeeperClient.doGetContent(String path)
focal_class.full_signature: @Override public String doGetContent(String path)
focal_class.identifier: doGetContent
focal_class.modifiers: @Override public
focal_class.parameters: (String path)
focal_class.return: String
focal_class.signature: String doGetContent(String path)
focal_class.class_method_signature: CuratorZookeeperClient.doClose()
focal_class.full_signature: @Override public void doClose()
focal_class.identifier: doClose
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void doClose()
focal_class.class_method_signature: CuratorZookeeperClient.createTargetChildListener(String path, ChildListener listener)
focal_class.full_signature: @Override public CuratorZookeeperClient.CuratorWatcherImpl createTargetChildListener(String path, ChildListener listener)
focal_class.identifier: createTargetChildListener
focal_class.modifiers: @Override public
focal_class.parameters: (String path, ChildListener listener)
focal_class.return: CuratorZookeeperClient.CuratorWatcherImpl
focal_class.signature: CuratorZookeeperClient.CuratorWatcherImpl createTargetChildListener(String path, ChildListener listener)
focal_class.class_method_signature: CuratorZookeeperClient.addTargetChildListener(String path, CuratorWatcherImpl listener)
focal_class.full_signature: @Override public List<String> addTargetChildListener(String path, CuratorWatcherImpl listener)
focal_class.identifier: addTargetChildListener
focal_class.modifiers: @Override public
focal_class.parameters: (String path, CuratorWatcherImpl listener)
focal_class.return: List<String>
focal_class.signature: List<String> addTargetChildListener(String path, CuratorWatcherImpl listener)
focal_class.class_method_signature: CuratorZookeeperClient.createTargetDataListener(String path, DataListener listener)
focal_class.full_signature: @Override protected CuratorZookeeperClient.CuratorWatcherImpl createTargetDataListener(String path, DataListener listener)
focal_class.identifier: createTargetDataListener
focal_class.modifiers: @Override protected
focal_class.parameters: (String path, DataListener listener)
focal_class.return: CuratorZookeeperClient.CuratorWatcherImpl
focal_class.signature: CuratorZookeeperClient.CuratorWatcherImpl createTargetDataListener(String path, DataListener listener)
focal_class.class_method_signature: CuratorZookeeperClient.addTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.full_signature: @Override protected void addTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.identifier: addTargetDataListener
focal_class.modifiers: @Override protected
focal_class.parameters: (String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.return: void
focal_class.signature: void addTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.class_method_signature: CuratorZookeeperClient.addTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener, Executor executor)
focal_class.full_signature: @Override protected void addTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener, Executor executor)
focal_class.identifier: addTargetDataListener
focal_class.modifiers: @Override protected
focal_class.parameters: (String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener, Executor executor)
focal_class.return: void
focal_class.signature: void addTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener, Executor executor)
focal_class.class_method_signature: CuratorZookeeperClient.removeTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.full_signature: @Override protected void removeTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.identifier: removeTargetDataListener
focal_class.modifiers: @Override protected
focal_class.parameters: (String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.return: void
focal_class.signature: void removeTargetDataListener(String path, CuratorZookeeperClient.CuratorWatcherImpl treeCacheListener)
focal_class.class_method_signature: CuratorZookeeperClient.removeTargetChildListener(String path, CuratorWatcherImpl listener)
focal_class.full_signature: @Override public void removeTargetChildListener(String path, CuratorWatcherImpl listener)
focal_class.identifier: removeTargetChildListener
focal_class.modifiers: @Override public
focal_class.parameters: (String path, CuratorWatcherImpl listener)
focal_class.return: void
focal_class.signature: void removeTargetChildListener(String path, CuratorWatcherImpl listener)
focal_class.class_method_signature: CuratorZookeeperClient.getClient()
focal_class.full_signature:  CuratorFramework getClient()
focal_class.identifier: getClient
focal_class.parameters: ()
focal_class.return: CuratorFramework
focal_class.signature: CuratorFramework getClient()
focal_class.superclass: extends AbstractZookeeperClient<CuratorZookeeperClient.CuratorWatcherImpl, CuratorZookeeperClient.CuratorWatcherImpl>
focal_method.body: @Override
      public boolean checkExists(String path) {
          try {
              if (client.checkExists().forPath(path) != null) {
                  return true;
              }
          } catch (Exception e) {
          }
          return false;
      }
focal_method.class_method_signature: CuratorZookeeperClient.checkExists(String path)
focal_method.full_signature: @Override public boolean checkExists(String path)
focal_method.identifier: checkExists
focal_method.invocations: forPath checkExists
focal_method.modifiers: @Override public
focal_method.parameters: (String path)
focal_method.return: boolean
focal_method.signature: boolean checkExists(String path)