Package com.swiftmq.impl.mqtt.pubsub

Class DurableConsumer

java.lang.Object

com.swiftmq.impl.mqtt.pubsub.Consumer

com.swiftmq.impl.mqtt.pubsub.DurableConsumer

public class DurableConsumer
extends Consumer

Field Summary

Fields inherited from class com.swiftmq.impl.mqtt.pubsub.Consumer

queueReceiver, readTransaction, transaction

Constructor Summary

Constructors

Constructor	Description
DurableConsumer(SwiftletContext ctx, MQTTSession session, String topicName, int subscriptionId)

Method Summary

Modifier and Type	Method	Description
void	close()
protected QueueReceiver	createReceiver(int subscriptionId)
String	toString()

Methods inherited from class com.swiftmq.impl.mqtt.pubsub.Consumer

createReadTransaction, createTransaction, restart, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

DurableConsumer

public DurableConsumer(SwiftletContext ctx,
 MQTTSession session,
 String topicName,
 int subscriptionId)
                throws Exception

Throws:

Exception

Method Details

createReceiver

protected QueueReceiver createReceiver(int subscriptionId)
                                throws Exception

Overrides:

createReceiver in class Consumer

Throws:

Exception

close

public void close()

Overrides:

close in class Consumer

toString

public String toString()

Overrides:

toString in class Consumer