@Test(dependsOnMethods = {"testEarlySubscriberForLaterWindow"})

public void testAuth() throws InterruptedException
{
  instance.setAuthToken(authToken);
  bsp = new Publisher("MyPublisher");
  bsp.setToken(authToken);
  eventloopClient.connect(address, bsp);
  bss = new Subscriber("MySubscriber");
  bss.setToken(authToken);
  eventloopClient.connect(address, bss);
  bsp.activate(null, 0L);
  bss.activate(null, "BufferServerOutput/BufferServerSubscriber", "MyPublisher", 0, null, 0L, 0);
  long resetInfo = 0x7afebabe000000faL;
  bsp.publishMessage(ResetWindowTuple.getSerializedTuple((int)(resetInfo >> 32), 500));
  for (int i = 0; i < spinCount; i++) {
    Thread.sleep(10);
    if (!bss.resetPayloads.isEmpty()) {
      break;
    }
  }
  Thread.sleep(10);
  eventloopClient.disconnect(bss);
  eventloopClient.disconnect(bsp);
  assertEquals(bss.tupleCount.get(), 1);
  assertFalse(bss.resetPayloads.isEmpty());
}