@Override
        public void onMessage(Message message) {
            byte[] data = message.getData();
            ByteArrayDataInput input = ByteStreams.newDataInput(data);
            String messageAsString = input.readUTF();

            NatsMessenger.this.consumer.consumeIncomingMessageAsString(messageAsString);
        }
An implementation of Messenger for Nats messaging client.
common/src/main/java/me/lucko/luckperms/common/messaging/nats/NatsMessenger.java