in src/main/java/com/googlesource/gerrit/plugins/multisite/forwarder/router/IndexEventRouter.java [64:86]
public void route(IndexEvent sourceEvent) throws IOException {
if (sourceEvent instanceof ChangeIndexEvent) {
ChangeIndexEvent changeIndexEvent = (ChangeIndexEvent) sourceEvent;
ForwardedIndexingHandler.Operation operation = changeIndexEvent.deleted ? DELETE : INDEX;
indexChangeHandler.index(
changeIndexEvent.projectName + "~" + changeIndexEvent.changeId,
operation,
Optional.of(changeIndexEvent));
} else if (sourceEvent instanceof AccountIndexEvent) {
AccountIndexEvent accountIndexEvent = (AccountIndexEvent) sourceEvent;
indexAccountHandler.indexAsync(Account.id(accountIndexEvent.accountId), INDEX);
} else if (sourceEvent instanceof GroupIndexEvent) {
GroupIndexEvent groupIndexEvent = (GroupIndexEvent) sourceEvent;
indexGroupHandler.index(groupIndexEvent.groupUUID, INDEX, Optional.of(groupIndexEvent));
} else if (sourceEvent instanceof ProjectIndexEvent) {
ProjectIndexEvent projectIndexEvent = (ProjectIndexEvent) sourceEvent;
indexProjectHandler.index(
projectIndexEvent.projectName, INDEX, Optional.of(projectIndexEvent));
} else {
throw new UnsupportedOperationException(
String.format("Cannot route event %s", sourceEvent.getType()));
}
}