for (int i = 0; i < NB_MESSAGES; i++) {
messages.add(System.currentTimeMillis());
}
ZkClient zkClient = new ZkClient("localhost:2181");
zkClient.create("/test", 0, CreateMode.PERSISTENT);
final ZooKeeper zk = CommTestUtils.createZkClient();
final CountDownLatch signalMessagesReceived = new CountDownLatch(1);
// watch for last message in test data sequence