@Test
public void testGetParticipantNodes() throws Exception
{

    final int LEASES = 3;
    Timing timing = new Timing();
    CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
    List<Lease> leases = Lists.newArrayList();
    client.start();
    try
    {
        InterProcessSemaphoreV2 semaphore = new InterProcessSemaphoreV2(client, "/test", LEASES);
        for ( int i = 0; i < LEASES; ++i )
        {
            leases.add(semaphore.acquire());
        }
        Assert.assertEquals(semaphore.getParticipantNodes().size(), LEASES);
    }
    finally
    {
        for ( Lease l : leases )
        {
            CloseableUtils.closeQuietly(l);
        }
        TestCleanState.closeAndTestClean(client);
    }
}