in src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageMessageFactory.java [85:98]
public PackageMessage create(
DistributionPackageBuilder packageBuilder,
ResourceResolver resourceResolver,
String pubAgentName,
DistributionRequest request)
throws DistributionException {
switch (request.getRequestType()) {
case ADD: return createAdd(packageBuilder, resourceResolver, pubAgentName, request);
case DELETE: return createDelete(packageBuilder, resourceResolver, request, pubAgentName);
case INVALIDATE: return createInvalidate(packageBuilder, resourceResolver, request, pubAgentName);
case TEST: return createTest(packageBuilder, resourceResolver, request, pubAgentName);
default: throw new IllegalArgumentException(format("Unsupported request with requestType=%s", request.getRequestType()));
}
}