firstGetter.start();
assertEquals(testCommand, firstGetter.getResult());
assertTrue(queue.putContent(completeCommand));
secondGetter = new TrackableThread(new AsyncCommandGetter(), "launching firstGetter");
secondGetter.start();
assertEquals(completeCommand, secondGetter.getResult());
}
public void testPollReturnsPoisonOncePoisonedAndPoisonPollersIsCalled() throws Throwable {
queue.setPoison(poisonString);