in amazon-sns-trigger-server/src/main/java/jetbrains/buildServer/clouds/amazon/sns/trigger/service/AwsSnsBuildTriggerState.java [56:75]
public void persist(Set<String> registeredMessagesIds) {
Map<String, SnsNotificationDto> messages = getRegisteredMessages();
for (String id : registeredMessagesIds) {
messages.remove(id);
}
if (messages.isEmpty()) {
myStorage.putValue(TRIGGER_STORE_MESSAGES, null);
} else {
try {
myStorage.putValue(TRIGGER_STORE_MESSAGES, myObjectMapper.writeValueAsString(messages));
} catch (JsonProcessingException err) {
myLogger.error("Something went terribly wrong. Try to recreate the trigger.", err);
throw new IllegalStateException(err);
}
}
myStorage.flush();
}