in mail-archive/server/src/main/java/org/apache/sling/mailarchiveserver/impl/MessageStoreImpl.java [228:250]
public void saveAll(Iterator<Message> iterator) throws IOException {
ResourceResolver resolver = null;
try {
resolver = getResourceResolver();
int mcount = 0;
while (iterator.hasNext()) {
Message msg = iterator.next();
save(resolver, msg);
mcount++;
if (mcount % 100 == 0) {
logger.debug(mcount+" messages processed.");
}
}
logger.info(mcount+" messages processed.");
} catch(LoginException e) {
throw new RuntimeException("LoginException", e);
} finally {
if(resolver != null) {
resolver.close();
}
}
}