in src/main/java/org/apache/sling/distribution/agent/impl/TriggerAgentRequestHandler.java [61:90]
public void handle(@Nullable ResourceResolver resourceResolver, @NotNull DistributionRequest request) {
if (!active) {
log.warn("skipping agent handler as agent is disabled");
return;
}
if (resourceResolver != null) {
try {
agent.execute(resourceResolver, request);
} catch (Throwable t) {
log.error("Error executing handler {}", request, t);
}
} else {
ResourceResolver agentResourceResolver = null;
try {
agentResourceResolver = DistributionUtils.getResourceResolver(null, authenticationInfo.getAgentService(),
authenticationInfo.getSlingRepository(), authenticationInfo.getSubServiceName(),
authenticationInfo.getResourceResolverFactory());
agent.execute(agentResourceResolver, request);
} catch (Throwable e) {
log.error("Error executing handler {}", request, e);
} finally {
DistributionUtils.ungetResourceResolver(agentResourceResolver);
}
}
}