From 3ba72cbad5ca5eac4d7c94c0b028364b81398b45 Mon Sep 17 00:00:00 2001 From: andrea Date: Sat, 22 Feb 2014 20:04:28 +0100 Subject: [PATCH] Fixed buggy test, missed to rewind a buffer before submitting. --- .../mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java b/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java index 8147dea9..112ca557 100644 --- a/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java +++ b/broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java @@ -252,6 +252,7 @@ public class ProtocolProcessorTest { //Exercise ByteBuffer buffer = ByteBuffer.allocate(5).put("Hello".getBytes()); + buffer.rewind(); PublishEvent pubEvt = new PublishEvent(FAKE_TOPIC, AbstractMessage.QOSType.MOST_ONE, buffer, false, "FakeCLI", null); m_processor.processPublish(pubEvt);