@Override
public void handlePayload(ChannelBuf channelBuf, RemoteConnection remoteConnection, Platform.Type type) {
    byte[] msgDirBuf = channelBuf.readBytes(channelBuf.available());
    try {
        this.handlePluginMessage(msgDirBuf);
    } catch (Exception e) {
        p.getLogger().error("There was an unknown error when processing a forwarded vote.", e);
    }
}
 

@Override
public void handlePayload(ChannelBuf data, RemoteConnection connection, Type side) {

    ByteArrayDataInput dataInput = ByteStreams.newDataInput(data.array());
    CheckPermMessage checkMessage = new CheckPermMessage();
    checkMessage.readFrom(dataInput);

    CheckPermMessage message = new CheckPermMessage();
    message.readFrom(dataInput);

    checkPermissions((Player) connection, message);
}
 

@Override
public void handlePayload(ChannelBuf data, RemoteConnection connection, Type side) {
    ByteArrayDataInput dataInput = ByteStreams.newDataInput(data.array());
    SkinUpdateMessage updateMessage = new SkinUpdateMessage();
    updateMessage.readFrom(dataInput);

    String playerName = updateMessage.getPlayerName();
    Optional<Player> receiver = Sponge.getServer().getPlayer(playerName);
    if (receiver.isPresent()) {
        Runnable skinUpdater = new SkinApplier(plugin, (CommandSource) connection, receiver.get(), null, false);
        Task.builder().execute(skinUpdater).submit(plugin);
    }
}
 

@Override
public void handlePayload(@NonNull ChannelBuf buf, @NonNull RemoteConnection connection, [email protected] Type type) {
    String msg = buf.readUTF();
    this.consumer.consumeIncomingMessageAsString(msg);
}