@Override
    public void sendOutgoingMessage(@NonNull OutgoingMessage outgoingMessage) {
        ByteArrayDataOutput output = ByteStreams.newDataOutput();
        output.writeUTF(outgoingMessage.asEncodedString());
        this.connection.publish(CHANNEL, output.toByteArray());
    }
An implementation of Messenger for Nats messaging client.
common/src/main/java/me/lucko/luckperms/common/messaging/nats/NatsMessenger.java