Class Subscription

java.lang.Object

com.swiftmq.swiftlet.queue.MessageProcessor

com.swiftmq.impl.mqtt.pubsub.Subscription

All Implemented Interfaces:

com.swiftmq.swiftlet.threadpool.AsyncTask, Runnable

public class Subscription
extends com.swiftmq.swiftlet.queue.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(com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
void	fillConnectionUsage(com.swiftmq.mgmt.Entity usageConnection)
void	fillRegistryUsage(com.swiftmq.mgmt.Entity usageRegistry)
int	getMsgsReceived()
SubscriptionStoreEntry	getStoreEntry()
String	getTopicName()
int	getTotalMsgsReceived()
boolean	isValid()
void	processException(Exception e)
void	processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
void	restart()
void	start()
void	stop()

Methods inherited from class com.swiftmq.swiftlet.queue.MessageProcessor

createBulkBuffer, getBulkBuffer, getCurrentBulkSize, getDescription, getDispatchToken, getMaxBulkSize, getReceiverId, getRegistrationId, getRegistrationTime, getSelector, getTimeout, getTransactionId, getViewId, isAutoCommit, isBulkMode, processMessages, reset, run, setAutoCommit, setBulkMode, setCurrentBulkSize, setReceiverId, setRegistrationId, setRegistrationTime, setTransactionId, setViewId

Methods inherited from class 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(com.swiftmq.mgmt.Entity usageRegistry)

fillConnectionUsage

public void fillConnectionUsage(com.swiftmq.mgmt.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()

Specified by:

stop in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

stop in class com.swiftmq.swiftlet.queue.MessageProcessor

processMessage

public void processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)

Specified by:

processMessage in class com.swiftmq.swiftlet.queue.MessageProcessor

processException

public void processException(Exception e)

Specified by:

processException in class com.swiftmq.swiftlet.queue.MessageProcessor

isValid

public boolean isValid()

close

public void close()

close

public void close(com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)