From 70ad0c0475543d14f283f7f1446711574709624b Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Tue, 4 Sep 2012 15:46:24 +0200 Subject: [PATCH] Removed no more used Unsubscribe event --- .../messaging/spi/impl/SimpleMessaging.java | 4 +-- .../spi/impl/events/UnsubscribeEvent.java | 25 ------------------- 2 files changed, 1 insertion(+), 28 deletions(-) delete mode 100644 parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/events/UnsubscribeEvent.java diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java index a4423586..0c003f3a 100644 --- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java +++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java @@ -193,9 +193,7 @@ public class SimpleMessaging implements IMessaging, EventHandler { processPublish((PublishEvent) evt); } else if (evt instanceof SubscribeEvent) { processSubscribe((SubscribeEvent) evt); - } /*else if (evt instanceof UnsubscribeEvent) { - processUnsubscribe((UnsubscribeEvent) evt); - } */else if (evt instanceof StopEvent) { + } else if (evt instanceof StopEvent) { processStop(); } else if (evt instanceof DisconnectEvent) { DisconnectEvent disEvt = (DisconnectEvent) evt; diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/events/UnsubscribeEvent.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/events/UnsubscribeEvent.java deleted file mode 100644 index ab752088..00000000 --- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/events/UnsubscribeEvent.java +++ /dev/null @@ -1,25 +0,0 @@ -package org.dna.mqtt.moquette.messaging.spi.impl.events; - -/** - * - * @author andrea - */ -public class UnsubscribeEvent extends MessagingEvent { - - String m_topic; - String m_clientID; - - public UnsubscribeEvent(String topic, String clientID) { - m_topic = topic; - m_clientID = clientID; - } - - public String getTopic() { - return m_topic; - } - - public String getClientID() { - return m_clientID; - } - -}