Package com.swiftmq.impl.mqtt.pubsub

Class Subscription

java.lang.Object

MessageProcessor

com.swiftmq.impl.mqtt.pubsub.Subscription

public class Subscription
extends MessageProcessor

Constructor Summary

Constructors

Constructor	Description
Subscription(SwiftletContext ctx, MQTTSession session, SubscriptionStoreEntry subscriptionStoreEntry)
Subscription(SwiftletContext ctx, MQTTSession session, String topicName, String topicNameTranslated, MqttQoS qos)

Method Summary

Modifier and Type	Method	Description
void	close()
void	close(ActiveLogin activeLogin)
void	fillConnectionUsage(Entity usageConnection)
void	fillRegistryUsage(Entity usageRegistry)
int	getMsgsReceived()
SubscriptionStoreEntry	getStoreEntry()
String	getTopicName()
int	getTotalMsgsReceived()
boolean	isValid()
void	processException(Exception e)
void	processMessage(MessageEntry messageEntry)
void	restart()
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Subscription

public Subscription(SwiftletContext ctx,
 MQTTSession session,
 String topicName,
 String topicNameTranslated,
 MqttQoS qos)

Subscription

public Subscription(SwiftletContext ctx,
 MQTTSession session,
 SubscriptionStoreEntry subscriptionStoreEntry)

Method Details

getTopicName

public String getTopicName()

getStoreEntry

public SubscriptionStoreEntry getStoreEntry()

fillRegistryUsage

public void fillRegistryUsage(Entity usageRegistry)

fillConnectionUsage

public void fillConnectionUsage(Entity usageConnection)

getMsgsReceived

public int getMsgsReceived()

getTotalMsgsReceived

public int getTotalMsgsReceived()

start

public void start()
           throws Exception

Throws:

Exception

restart

public void restart()
             throws Exception

Throws:

Exception

stop

public void stop()

processMessage

public void processMessage(MessageEntry messageEntry)

processException

public void processException(Exception e)

isValid

public boolean isValid()

close

public void close()

close

public void close(ActiveLogin activeLogin)