msgsend.java

package de.Panakotta00.msgsend;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;

import org.bukkit.Bukkit;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.plugin.java.JavaPlugin;
import org.bukkit.plugin.messaging.PluginMessageListener;

import com.google.common.io.ByteArrayDataOutput;
import com.google.common.io.ByteStreams;

public class msgsend extends JavaPlugin implements PluginMessageListener {
    private static msgsend instance;

    @Override
    public void onEnable() {
        instance = this;

        this.getServer().getMessenger().registerOutgoingPluginChannel(this, "BungeeCord");
        this.getServer().getMessenger().registerIncomingPluginChannel(this, "BungeeCord", this);
    }

    @Override
    public void onPluginMessageReceived(String channel, Player player, byte[] message) {
        if (!channel.equals("BungeeCord")) {
            return;
        }

        try {
            DataInputStream in = new DataInputStream(new ByteArrayInputStream(message));
            String subchannel = in.readUTF();
            if (subchannel.equals("customchannel")) {
                short len = in.readShort();
                byte[] data = new byte[len];
                in.readFully(data);

                //bytearray to string
                String s = new String(data);

                System.out.println(s);
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public void forwardString(String subchannel, String target, String s) {
        try {
            ByteArrayOutputStream b = new ByteArrayOutputStream();
            DataOutputStream out = new DataOutputStream(b);

            out.writeUTF("Forward");
            out.writeUTF(target);
            out.writeUTF(subchannel); // "customchannel" for example
            byte[] data = s.getBytes();
            out.writeShort(data.length);
            out.write(data);

            Player p = Bukkit.getPlayer("Panakotta00");

            p.sendPluginMessage(instance, "BungeeCord", b.toByteArray());
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public static msgsend getInstance() {
        return instance;
    }

    @SuppressWarnings("deprecation")
    public boolean onCommand(CommandSender sender, Command cmd, String cmdLabel, String[] args) {
        if (sender != Bukkit.getConsoleSender()) {
            Player p = (Player) sender;

            if (cmd.getName().equalsIgnoreCase("msg")) {
                forwardString("customchannel", "ALL", "Servus");
            }
        }
        return true;
    }
}