in repository/service/src/main/java/org/apache/karaf/cave/repository/service/scheduler/RepositoryJob.java [39:70]
public void execute(JobContext jobContext) {
LOGGER.info("Executing scheduler for repository {}", repository.getName());
String[] actions = repository.getSchedulingAction().split(",");
for (String action : actions) {
if (action.equalsIgnoreCase("purge")) {
try {
repositoryService.purge(repository.getName());
} catch (Exception e) {
LOGGER.error("Can't purge repository {}", repository.getName(), e);
}
} else if (action.equalsIgnoreCase("delete")) {
try {
repositoryService.remove(repository.getName());
} catch (Exception e) {
LOGGER.error("Can't delete repository {}", repository.getName(), e);
}
} else if (action.contains("copy")) {
String[] destinationRepository = action.split(" ");
if (destinationRepository.length != 2) {
LOGGER.error("Ambiguous destination repository in action {} for repository {}", action, repository.getName());
} else {
try {
repositoryService.copy(repository.getName(), destinationRepository[1]);
} catch (Exception e) {
LOGGER.error("Can't copy repository {} to repository {}", repository.getName(), destinationRepository[1], e);
}
}
} else {
LOGGER.error("Unknown scheduling action {} in repository {}", action, repository.getName());
}
}
}