@Test(dependsOnMethods = {"testATonOfData"})

@SuppressWarnings("SleepWhileInLoop")
public void testPurgeNonExistent() throws InterruptedException
{
  bsc = new Controller("MyController");
  eventloopClient.connect(address, bsc);
  bsc.purge(null, "MyPublisher", 0);
  for (int i = 0; i < spinCount; i++) {
    Thread.sleep(10);
    if (bsc.data != null) {
      break;
    }
  }
  eventloopClient.disconnect(bsc);
  assertNotNull(bsc.data);
  bss = new Subscriber("MyPublisher");
  eventloopClient.connect(address, bss);
  bss.activate(null, "BufferServerOutput/BufferServerSubscriber", "MyPublisher", 0, null, 0L, 0);
  for (int i = 0; i < spinCount; i++) {
    Thread.sleep(10);
    if (bss.tupleCount.get() == 205) {
      break;
    }
  }
  Thread.sleep(10);
  eventloopClient.disconnect(bss);
  assertEquals(bss.tupleCount.get(), 205);
}