@Override
        public void handle(String consumerTag, Delivery message) {
            try {
                byte[] data = message.getBody();
                ByteArrayDataInput input = ByteStreams.newDataInput(data);
                String msg = input.readUTF();
                RabbitMQMessenger.this.consumer.consumeIncomingMessageAsString(msg);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
Checks the connection, and re-opens it if necessary.

@return true if the connection is now alive, false otherwise
common/src/main/java/me/lucko/luckperms/common/messaging/rabbitmq/RabbitMQMessenger.java