in src/main/java/com/ericsson/gerrit/plugins/eventslog/sql/SQLStore.java [141:168]
public void storeEvent(ProjectEvent event) {
Project.NameKey projectName = event.getProjectNameKey();
if (projectName == null) {
return;
}
int failedConnections = 0;
boolean done = false;
while (!done) {
done = true;
try {
getEventsDb().storeEvent(event);
} catch (SQLException e) {
log.atWarning().withCause(e).log("Cannot store ChangeEvent for: %s}", projectName.get());
if (e.getCause() instanceof ConnectException
|| e.getMessage().contains("terminating connection")) {
done = false;
try {
retryIfAllowed(failedConnections);
} catch (InterruptedException e1) {
log.atWarning().log("Cannot store ChangeEvent for %s: Interrupted", projectName.get());
Thread.currentThread().interrupt();
return;
}
failedConnections++;
}
}
}
}