in src/main/java/org/apache/sling/distribution/journal/bookkeeper/PackageHandler.java [56:70]
public void apply(ResourceResolver resolver, PackageMessage pkgMsg)
throws DistributionException, PersistenceException {
PackageMessage.ReqType type = pkgMsg.getReqType();
switch (type) {
case ADD:
installAddPackage(resolver, pkgMsg);
break;
case DELETE:
installDeletePackage(resolver, pkgMsg);
break;
case TEST:
break;
default: throw new UnsupportedOperationException(format("Unable to process messages with type: %s", type));
}
}