Fixed issue #40

broker/src/main/java/org/eclipse/moquette/spi/impl/ProtocolProcessor.java

@@ -667,11 +667,15 @@ class ProtocolProcessor implements EventHandler<ValueEvent> {
     }
 
     public void onEvent(ValueEvent t, long l, boolean bln) throws Exception {
-        MessagingEvent evt = t.getEvent();
-        //It's always of type OutputMessagingEvent
-        OutputMessagingEvent outEvent = (OutputMessagingEvent) evt;
-        LOG.debug("Output event, sending {}", outEvent.getMessage());
-        outEvent.getChannel().write(outEvent.getMessage());
+        try {
+            MessagingEvent evt = t.getEvent();
+            //It's always of type OutputMessagingEvent
+            OutputMessagingEvent outEvent = (OutputMessagingEvent) evt;
+            LOG.debug("Output event, sending {}", outEvent.getMessage());
+            outEvent.getChannel().write(outEvent.getMessage());
+        } finally {
+            t.setEvent(null); //free the reference to all Netty stuff
+        }
     }
 
 }

broker/src/main/java/org/eclipse/moquette/spi/impl/SimpleMessaging.java

@@ -153,6 +153,7 @@ public class SimpleMessaging implements IMessaging, EventHandler<ValueEvent> {
     @Override
     public void onEvent(ValueEvent t, long l, boolean bln) throws Exception {
         MessagingEvent evt = t.getEvent();
+        t.setEvent(null); //free the reference to all Netty stuff
         LOG.info("onEvent processing messaging event from input ringbuffer {}", evt);
         if (evt instanceof StopEvent) {
             processStop();