🔥 Plugin Message system removed

Author: CustomEntity

build.gradle

@@ -3,7 +3,7 @@ import org.apache.tools.ant.filters.ReplaceTokens
 apply plugin: 'java'
 
 group = 'fr.customentity'
-version = '0.3'
+version = '0.3.1'
 
 sourceCompatibility = '1.8'
 targetCompatibility = '1.8'

src/main/java/fr/customentity/advancedbungeequeue/bungee/AdvancedBungeeQueue.java

@@ -42,8 +42,6 @@ public void onEnable() {
         this.getProxy().getPluginManager().registerCommand(this, new QueueCommand(this));
         this.getProxy().getPluginManager().registerListener(this, new QueueListener(this));
 
-        this.getProxy().registerChannel("AdvancedBungeeQueue");
-
         this.getProxy().getScheduler().schedule(this, () -> queueManager.getQueues().forEach((serverInfo, queuedPlayers) -> queuedPlayers.forEach(queuedPlayer -> this.sendConfigMessage(queuedPlayer.getProxiedPlayer(), "general.repeating-position-message",
                 "%all%", queuedPlayers.size() + "",
                 "%position%", queuedPlayers.indexOf(queuedPlayer) + 1 + "",

src/main/java/fr/customentity/advancedbungeequeue/bungee/listener/QueueListener.java

@@ -1,16 +1,10 @@
 package fr.customentity.advancedbungeequeue.bungee.listener;
 
-import com.google.common.io.ByteArrayDataInput;
-import com.google.common.io.ByteStreams;
 import fr.customentity.advancedbungeequeue.bungee.AdvancedBungeeQueue;
 import fr.customentity.advancedbungeequeue.bungee.data.QueuedPlayer;
-import net.md_5.bungee.api.CommandSender;
-import net.md_5.bungee.api.ProxyServer;
 import net.md_5.bungee.api.config.ServerInfo;
 import net.md_5.bungee.api.connection.ProxiedPlayer;
-import net.md_5.bungee.api.connection.Server;
 import net.md_5.bungee.api.event.PlayerDisconnectEvent;
-import net.md_5.bungee.api.event.PluginMessageEvent;
 import net.md_5.bungee.api.event.ServerSwitchEvent;
 import net.md_5.bungee.api.plugin.Listener;
 import net.md_5.bungee.event.EventHandler;
@@ -35,29 +29,15 @@ public void onDisconnect(PlayerDisconnectEvent event) {
     @EventHandler
     public void onSwitch(ServerSwitchEvent event) {
         ServerInfo from = event.getFrom();
-        if(from == null)return;
+        if (from == null) return;
         if (plugin.getConfigFile().getStringList("default-servers").stream().noneMatch(s -> from.getName().contains(s))) {
             return;
         }
         Optional<QueuedPlayer> queuedPlayer = QueuedPlayer.get(event.getPlayer());
-        if(!queuedPlayer.isPresent())return;
+        if (!queuedPlayer.isPresent()) return;
 
-        if(!queuedPlayer.get().isConnecting()) {
+        if (!queuedPlayer.get().isConnecting()) {
             plugin.getQueueManager().removePlayerFromQueue(queuedPlayer.get());
         }
     }
-
-    @EventHandler
-    public void onReceive(PluginMessageEvent event) {
-        if(!(event.getSender() instanceof Server))return;
-        String channel = event.getTag();
-        if(channel.equalsIgnoreCase("AdvancedBungeeQueue")) {
-            ByteArrayDataInput in = ByteStreams.newDataInput(event.getData());
-            String subChannel = in.readUTF();
-            String command = in.readUTF();
-            if(subChannel.equalsIgnoreCase("ExecuteCommand")) {
-                plugin.getProxy().getPluginManager().dispatchCommand((CommandSender) event.getReceiver(), command);
-            }
-        }
-    }
 }

src/main/java/fr/customentity/advancedbungeequeue/spigot/AdvancedSpigotQueue.java

@@ -25,7 +25,6 @@ public void onEnable() {
 
         Bukkit.getPluginManager().registerEvents(this, this);
 
-        Bukkit.getMessenger().registerOutgoingPluginChannel(this, "AdvancedBungeeQueue");
         this.socketManager = new SocketManager(this);
     }