fix rare concurrency error

ajgeiss0702 · Aug 5, 2022 · b545687 · b545687
1 parent c2bac1c
commit b545687
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/common/src/main/java/us/ajg0702/queue/common/QueueManagerImpl.java b/common/src/main/java/us/ajg0702/queue/common/QueueManagerImpl.java
@@ -352,7 +352,8 @@ public void sendActionBars() {
                 AdaptedPlayer player = queuePlayer.getPlayer();
                 if(player == null) continue;
 
-                if(!getSingleServer(player).equals(server)) continue;
+                QueueServer singleServer = getSingleServer(player);
+                if(singleServer == null || !singleServer.equals(server)) continue;
 
                 if(!server.isJoinable(player)) {
                     player.sendActionBar(msgs.getComponent("spigot.actionbar.offline",
@@ -392,7 +393,8 @@ public void sendTitles() {
                 AdaptedPlayer player = queuePlayer.getPlayer();
                 if(player == null) continue;
 
-                if(!getSingleServer(player).equals(server)) continue;
+                QueueServer singleServer = getSingleServer(player);
+                if(singleServer == null || !singleServer.equals(server)) continue;
 
                 int time = (int) Math.round(pos * main.getTimeBetweenPlayers());