Removed no more used Unsubscribe event
This commit is contained in:
@@ -193,9 +193,7 @@ public class SimpleMessaging implements IMessaging, EventHandler<ValueEvent> {
|
||||
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;
|
||||
|
||||
-25
@@ -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;
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user