in wilma-application/modules/wilma-safeguard/src/main/java/com/epam/wilma/safeguard/monitor/JmsQueueMonitorTask.java [174:195]
private void setSafeguardFlags(final Long totalQueueSize) {
if (fIDecompressionEnabled && totalQueueSize > safeguardLimits.getFiOffLimit()) {
fIDecompressionEnabled = false;
safeguardController.setFIDecompressionEnabled(fIDecompressionEnabled);
logger.info("Due to High load, FI decompression is turned OFF.");
}
if (messageWritingEnabled && totalQueueSize > safeguardLimits.getMwOffLimit()) {
messageWritingEnabled = false;
safeguardController.setMessageWritingEnabled(messageWritingEnabled);
logger.info("Due to High load, Message Logging is turned OFF.");
}
if (!messageWritingEnabled && totalQueueSize < safeguardLimits.getMwOnLimit()) {
messageWritingEnabled = true;
safeguardController.setMessageWritingEnabled(messageWritingEnabled);
logger.info("Due to Normal load, Message Logging is restored.");
}
if (!fIDecompressionEnabled && totalQueueSize < safeguardLimits.getFiOnLimit()) {
fIDecompressionEnabled = true;
safeguardController.setFIDecompressionEnabled(fIDecompressionEnabled);
logger.info("Due to Normal load, FI decompression is restored.");
}
}