in src/main/java/org/apache/sling/discovery/base/connectors/announcement/AnnouncementRegistryImpl.java [553:582]
private final void deleteAnnouncementsOf(final String instanceId) {
ResourceResolver resourceResolver = null;
try {
resourceResolver = resourceResolverFactory
.getServiceResourceResolver(null);
ResourceHelper.deleteResource(resourceResolver,
config.getClusterInstancesPath()
+ "/"
+ slingId
+ "/announcements/"
+ instanceId);
resourceResolver.commit();
resourceResolver.close();
resourceResolver = null;
} catch (LoginException e) {
logger.error(
"deleteAnnouncementsOf: could not log in administratively when deleting "
+ "announcements of instanceId="+instanceId+": " + e, e);
} catch (PersistenceException e) {
logger.error(
"deleteAnnouncementsOf: got PersistenceException when deleting "
+ "announcements of instanceId="+instanceId+": " + e, e);
} finally {
if (resourceResolver!=null) {
resourceResolver.revert();
resourceResolver.close();
resourceResolver = null;
}
}
}