diff --git a/src/main/java/us/ajg0702/queue/Manager.java b/src/main/java/us/ajg0702/queue/Manager.java index fd7c23b..f7abebe 100644 --- a/src/main/java/us/ajg0702/queue/Manager.java +++ b/src/main/java/us/ajg0702/queue/Manager.java @@ -335,7 +335,10 @@ public class Manager { for(Iterator it = servers.iterator(); it.hasNext();) { QueueServer s = it.next(); for(Iterator pit = s.getQueue().iterator(); pit.hasNext();) { - BungeeUtils.sendCustomData(pit.next(), "inqueueevent", "true"); + ProxiedPlayer player = pit.next(); + if(player == null) continue; + if(!player.isConnected()) continue; + BungeeUtils.sendCustomData(player, "inqueueevent", "true"); } } } diff --git a/src/main/java/us/ajg0702/queue/QueueServer.java b/src/main/java/us/ajg0702/queue/QueueServer.java index 9d15f9e..7cb3c91 100644 --- a/src/main/java/us/ajg0702/queue/QueueServer.java +++ b/src/main/java/us/ajg0702/queue/QueueServer.java @@ -144,7 +144,7 @@ public class QueueServer { List queue = new ArrayList<>(); - public List getQueue() { + public synchronized List getQueue() { return queue; }