diff --git a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/DebugUtils.java b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/DebugUtils.java new file mode 100644 index 00000000..a0703bfd --- /dev/null +++ b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/DebugUtils.java @@ -0,0 +1,17 @@ +package org.dna.mqtt.moquette.messaging.spi.impl; + +import java.nio.ByteBuffer; + +/** + * + * @author andrea + */ +class DebugUtils { + static String payload2Str(ByteBuffer content) { + byte[] b = new byte[content.remaining()]; + content.mark(); + content.get(b); + content.reset(); + return new String(b); + } +}