From 0e729b51bfabb36c21ed0a4731c14f7b9bc57340 Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Sun, 17 Aug 2014 16:58:51 +0200 Subject: [PATCH] Used annotation dispatch for some protocol messages --- .../mqtt/moquette/messaging/spi/impl/SimpleMessaging.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java index 1ec4f9c9..df83a1b1 100644 --- a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java +++ b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java @@ -94,8 +94,8 @@ public class SimpleMessaging implements IMessaging, EventHandler { m_executor.submit(m_eventProcessor); annotationHelper.processAnnotations(m_processor); - - disruptorPublish(new InitEvent(configProps)); + processInit(configProps); +// disruptorPublish(new InitEvent(configProps)); } @@ -174,9 +174,9 @@ public class SimpleMessaging implements IMessaging, EventHandler { throw new RuntimeException("Illegal message received " + message); } - } else if (evt instanceof InitEvent) { + } /*else if (evt instanceof InitEvent) { processInit(((InitEvent) evt).getConfig()); - } else if (evt instanceof LostConnectionEvent) { + } */else if (evt instanceof LostConnectionEvent) { LostConnectionEvent lostEvt = (LostConnectionEvent) evt; m_processor.proccessConnectionLost(lostEvt.getClientID()); }