in src/main/java/org/apache/sling/distribution/journal/bookkeeper/ContentPackageExtractor.java [111:129]
private void installPackage(String path, Node node) throws RepositoryException, PackageException, IOException {
log.info("Content package received at {}. Starting import", path);
StopWatch stopWatch = new StopWatch();
stopWatch.start();
Session session = node.getSession();
JcrPackageManager packMgr = packageService.getPackageManager(session);
ErrorListener listener = new ErrorListener(subscriberMetrics);
try (JcrPackage pack = packMgr.open(node)) {
if (pack != null) {
installPackage(pack, listener);
}
} catch (PackageException e) {
failed(listener.getLastErrorMessage(), e);
}
subscriberMetrics.getPackageInstallCount().increment();
long durationMS = stopWatch.getTime(TimeUnit.MILLISECONDS);
subscriberMetrics.getPackgeInstallDuration().update(durationMS, TimeUnit.MILLISECONDS);
log.info("Content package at {} installed in durationMS={}", path, durationMS);
}