OF-3153: Introduce option to configure failfast behavior of room loading

This introduces a new SystemProperty `xmpp.muc.loading.failfast` that controls if an exception while loading a room causes an error to be thrown (fail-fast), or will allow all other rooms to be loaded (resilient).

Note that this applies to non-SQL exceptions only, as SQL exceptions are logged but otherwise ignored by the `loadFromDB` method.

Author: guusdk

i18n/src/main/resources/openfire_i18n.properties

@@ -1369,6 +1369,7 @@ system_property.xmpp.muc.muclumbus.v1-0.enabled=Determine if the multi-user chat
 system_property.xmpp.muc.join.presence=Setting the presence send of participants joining in MUC rooms.
 system_property.xmpp.muc.join.self-presence-timeout=Maximum duration to wait for presence to be broadcast while joining a MUC room.
 system_property.xmpp.muc.bulkretraction=Enable or disable the bulk retraction of messages in MUC rooms.
+system_property.xmpp.muc.loading.failfast=If true, room loading aborts on the first failure (fail-fast); if false, all rooms are attempted (resilient).
 system_property.xmpp.muc.loading.timeout=Defines the maximum duration to wait for loading MUC rooms from the database at service startup. If the loading process exceeds this timeout, it will be aborted. A value of zero indicates that no timeout is configured, and the process may run indefinitely.
 system_property.xmpp.muc.loading.workers=Controls the number of parallel workers used when loading MUC rooms from the database at service startup. A value of 1 loads rooms sequentially. Values 2-5 enable parallel loading which can improve startup time for services with many rooms, but increases database load. Consider your database's connection pool size and capacity before increasing this value.
 system_property.ldap.authorizeField=Name of attribute in user's LDAP object used by the LDAP authorization policy.

i18n/src/main/resources/openfire_i18n_nl.properties

@@ -1278,6 +1278,7 @@ system_property.xmpp.muc.muclumbus.v1-0.enabled=Definieert of de multi-user chat
 system_property.xmpp.muc.join.presence=Wissel statusinformatie uit als een nieuwe participant een MUC ruimte binnentreedt.
 system_property.xmpp.muc.join.self-presence-timeout=Maximale wachttijd voor omgeroepen status informatie tijdens het binnentreden van een MUC ruimte.
 system_property.xmpp.muc.bulkretraction=Het in bulk intrekken van berichten in MUC-ruimtes in- of uitschakelen.
+system_property.xmpp.muc.loading.failfast=Als true, stopt het laden van MUC-ruimtes bij de eerste fout (fail-fast); als false, worden alle MUC-ruimtes geprobeerd (resilient).
 system_property.xmpp.muc.loading.timeout=Definieert de maximale duur om te wachten op het laden van MUC-rooms uit de database bij het opstarten van de service. Als het laadproces deze time-out overschrijdt, wordt het afgebroken. Een waarde van nul geeft aan dat er geen time-out is ingesteld en het proces mogelijk onbeperkt kan doorgaan.
 system_property.xmpp.muc.loading.workers=Stelt het aantal parallelle werkers in dat wordt gebruikt bij het laden van MUC-ruimtes uit de database tijdens het opstarten van de service. Een waarde van 1 laadt de ruimtes achtereenvolgens. Waarden van 2 tot 5 maken parallel laden mogelijk, wat de opstarttijd kan verbeteren voor services met veel ruimtes, maar de belasting van de database verhoogt. Houd rekening met de grootte en capaciteit van de connectiepool van uw database voordat u deze waarde verhoogt.
 system_property.ldap.authorizeField=Naam van kenmerk in het LDAP-object van de gebruiker dat door het LDAP-autorisatiebeleid wordt gebruikt.

xmppserver/src/main/java/org/jivesoftware/openfire/muc/spi/MUCPersistenceManager.java

@@ -37,12 +37,9 @@
 import java.time.temporal.ChronoUnit;
 import java.util.Date;
 import java.util.*;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.TimeUnit;
+import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicReference;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
@@ -93,6 +90,15 @@ public class MUCPersistenceManager {
         .setDefaultValue(Duration.ZERO)
         .build();
 
+    /**
+     * If true, room loading aborts on the first failure (fail-fast); if false, all rooms are attempted (resilient).
+     */
+    public static final SystemProperty<Boolean> ROOM_LOADING_FAILFAST = SystemProperty.Builder.ofType(Boolean.class)
+        .setKey("xmpp.muc.loading.failfast")
+        .setDynamic(false)
+        .setDefaultValue(true)
+        .build();
+
     private static final String GET_RESERVED_NAME =
         "SELECT nickname FROM ofMucMember WHERE roomID=? AND jid=?";
     private static final String LOAD_ROOM =
@@ -730,14 +736,22 @@ public static Collection<MUCRoom> loadRoomsFromDB(MultiUserChatService chatserve
             "MUC-RoomLoad-", Executors.defaultThreadFactory(), false, Thread.NORM_PRIORITY);
         final ExecutorService executor = Executors.newFixedThreadPool(workers, threadFactory);
         final AtomicInteger failedCount = new AtomicInteger(0);
+        final AtomicReference<Exception> firstFailure = new AtomicReference<>();
+        final boolean failFast = ROOM_LOADING_FAILFAST.getValue();
 
         for (MUCRoom room : rooms.values()) {
             executor.submit(() -> {
+                // Skip loading if fail-fast and a failure has already occurred
+                if (failFast && failedCount.get() > 0) {
+                    return;
+                }
+
                 try {
                     loadFromDB(room);
                 } catch (Exception e) {
                     Log.error("Failed to load room '{}' from database.", room.getName(), e);
                     failedCount.incrementAndGet();
+                    firstFailure.compareAndSet(null, e);
                 }
             });
         }
@@ -756,6 +770,9 @@ public static Collection<MUCRoom> loadRoomsFromDB(MultiUserChatService chatserve
         }
 
         if (failedCount.get() > 0) {
+            if (failFast) {
+                throw new RuntimeException("Failed to load a room for chat service " + chatserver.getServiceName(), firstFailure.get());
+            }
             Log.warn("Failed to load {} room(s) for chat service {}. See previous error messages for details.",
                 failedCount.get(), chatserver.getServiceName());
         }