@Test
public void testCreateClusterPaths() throws Exception {

  when(zk.create(anyString(), any(byte[].class), anyListOf(ACL.class), any(CreateMode.class)))
      .thenReturn("");
  ArgumentCaptor<String> pathCaptor = ArgumentCaptor.forClass(String.class);
  zkManager.createClusterPaths();
  verify(zk, times(3)).create(pathCaptor.capture(), any(byte[].class), anyListOf(ACL.class),
      any(CreateMode.class));
  Set<String> allPaths = Sets.newHashSet(pathCaptor.getAllValues());
  assertTrue(allPaths.contains(FILE_SET_DIR));
  assertTrue(allPaths.contains(VIEWS_DIR));
  assertTrue(allPaths.contains(LOCKS_DIR));
}