@Override
    public void registerForwardCallback(String channelName, Predicate<ByteArrayDataInput> callback) {
        final Predicate<ByteArrayDataInput> cb = Objects.requireNonNull(callback, "callback");
        ForwardCustomCallback customCallback = new ForwardCustomCallback(channelName, bytes -> cb.test(ByteStreams.newDataInput(bytes)));
        registerCallback(customCallback);
    }
Sends (or queues the sending of) the message encapsulated by the given message agent

@param agent the agent
helper/src/main/java/me/lucko/helper/messaging/bungee/BungeeCordImpl.java