@Test public void testRebuildNodeDoNotUseCache() throws Exception { testee = new ZkPathChildrenCacheWrapper(client, "/test", false, null); testee.rebuildNode("/test"); verify(cache, never()).rebuildNode(anyString()); }
@Override public void rebuildNode(final String path) { if (useCache || useCacheWhenNotConnectedToDataSource) { try { cache.rebuildNode(path); log.debug("Successfully rebuilt node cache for path={}", path); } catch (Exception e) { log.error("Failed to rebuild node cache for path={}", path, e); } } }
ZkPathChildrenCacheWrapper extends BaseCacheWrapper implements IPathChildrenCacheWrapper { @Override public void rebuildNode(final String path) { if (useCache || useCacheWhenNotConnectedToDataSource) { try { cache.rebuildNode(path); log.debug("Successfully rebuilt node cache for path={}", path); } catch (Exception e) { log.error("Failed to rebuild node cache for path={}", path, e); } } } }
ZkPathChildrenCacheWrapper extends BaseCacheWrapper implements IPathChildrenCacheWrapper { @Override public void rebuildNode(final String path) { if (useCache || useCacheWhenNotConnectedToDataSource) { try { cache.rebuildNode(path); log.debug("Successfully rebuilt node cache for path={}", path); } catch (Exception e) { log.error("Failed to rebuild node cache for path={}", path, e); } } } ZkPathChildrenCacheWrapper(IDataSourceConnector connector,
                                      String path,
                                      boolean dataIsCompressed,
                                      PathChildrenCache cache); }
ZkPathChildrenCacheWrapper extends BaseCacheWrapper implements IPathChildrenCacheWrapper { @Override public void rebuildNode(final String path) { if (useCache || useCacheWhenNotConnectedToDataSource) { try { cache.rebuildNode(path); log.debug("Successfully rebuilt node cache for path={}", path); } catch (Exception e) { log.error("Failed to rebuild node cache for path={}", path, e); } } } ZkPathChildrenCacheWrapper(IDataSourceConnector connector,
                                      String path,
                                      boolean dataIsCompressed,
                                      PathChildrenCache cache); @Override void start(final PathChildrenCache.StartMode startMode); @Override void addListener(PathChildrenCacheListener listener); @Override void rebuild(); @Override void close(); @Override void rebuildNode(final String path); @Override Map<String, byte[]> getNodeIdToDataMap(); @Override byte[] getCurrentData(String fullPath); boolean isUseCache(); }
ZkPathChildrenCacheWrapper extends BaseCacheWrapper implements IPathChildrenCacheWrapper { @Override public void rebuildNode(final String path) { if (useCache || useCacheWhenNotConnectedToDataSource) { try { cache.rebuildNode(path); log.debug("Successfully rebuilt node cache for path={}", path); } catch (Exception e) { log.error("Failed to rebuild node cache for path={}", path, e); } } } ZkPathChildrenCacheWrapper(IDataSourceConnector connector,
                                      String path,
                                      boolean dataIsCompressed,
                                      PathChildrenCache cache); @Override void start(final PathChildrenCache.StartMode startMode); @Override void addListener(PathChildrenCacheListener listener); @Override void rebuild(); @Override void close(); @Override void rebuildNode(final String path); @Override Map<String, byte[]> getNodeIdToDataMap(); @Override byte[] getCurrentData(String fullPath); boolean isUseCache();  }