Assert.assertTrue(sharder.getShardQty() > 1);
Set<String> consumed = Sets.newHashSet();
for ( int i = 0; i < 8; ++i )
{
String s = consumer.take(timing.forWaiting().milliseconds(), TimeUnit.MILLISECONDS);
Assert.assertNotNull(s);
consumed.add(s);
}
Assert.assertEquals(consumed, Sets.newHashSet("one", "two", "three", "four", "five", "six", "seven", "eight"));