@Test
public void testLockFileSet() throws Exception {

  when(zk.create(anyString(), any(byte[].class), anyListOf(ACL.class), any(CreateMode.class)))
      .thenReturn("");
  CreateMode mode = CreateMode.EPHEMERAL;
  zkManager.lockFileSet(FILE_SET, FILE_SET_INFO, mode);
  verify(zk).create(eq(FILE_SET_LOCK_PATH), any(byte[].class),
      anyListOf(ACL.class), eq(mode));
}