String usize1 = statsAggregator.aggregateStats("file_00001",
StatsSetupConst.RAW_DATA_SIZE);
assertEquals("3000", usize1);
// close connections
assertTrue(statsPublisher.closeConnection());
assertTrue(statsAggregator.closeConnection());
System.out
.println("StatsPublisher - one stat published per key - aggregating matching key - OK");
} catch (Throwable e) {