diff --git a/VotingPlugin/src/com/bencodez/votingplugin/bungee/global/multiproxy/MultiProxyHandler.java b/VotingPlugin/src/com/bencodez/votingplugin/bungee/global/multiproxy/MultiProxyHandler.java index 4a1376daa..41bce6212 100644 --- a/VotingPlugin/src/com/bencodez/votingplugin/bungee/global/multiproxy/MultiProxyHandler.java +++ b/VotingPlugin/src/com/bencodez/votingplugin/bungee/global/multiproxy/MultiProxyHandler.java @@ -94,7 +94,11 @@ public void onReceive(String[] data) { logInfo("Multi-proxy status message received"); } else if (data[0].equalsIgnoreCase("ClearVote")) { clearVote(data[2]); - // cachedOnlineVotes.remove(data[2]); + if (getPrimaryServer()) { + sendMultiProxyServerMessage("ClearVotePrimary", data[1], data[2]); + } + } else if (data[0].equalsIgnoreCase("ClearVotePrimary")) { + clearVote(data[2]); } else if (data[0].equalsIgnoreCase("login")) { addNonVotedPlayerCache(data[1], data[2]); // nonVotedPlayersCache.addPlayer(data[1], data[2]); @@ -134,7 +138,11 @@ public void onMessage(String channel, String[] data) { logInfo("Multi-proxy status message received"); } else if (data[0].equalsIgnoreCase("ClearVote")) { clearVote(data[2]); - // cachedOnlineVotes.remove(data[2]); + if (getPrimaryServer()) { + sendMultiProxyServerMessage("ClearVotePrimary", data[1], data[2]); + } + } else if (data[0].equalsIgnoreCase("ClearVotePrimary")) { + clearVote(data[2]); } else if (data[0].equalsIgnoreCase("login")) { addNonVotedPlayerCache(data[1], data[2]); // nonVotedPlayersCache.addPlayer(data[1], data[2]);