Package com.swiftmq.impl.mqtt.pubsub

Class Consumer

java.lang.Object

com.swiftmq.impl.mqtt.pubsub.Consumer

Direct Known Subclasses:

DurableConsumer

public class Consumer
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected QueueReceiver	queueReceiver
protected QueuePullTransaction	readTransaction
protected QueuePullTransaction	transaction

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
QueuePullTransaction	createReadTransaction()
protected QueueReceiver	createReceiver(int subscriptionId)
QueuePullTransaction	createTransaction()
void	restart()
void	start(MessageProcessor messageProcessor)
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

queueReceiver

protected QueueReceiver queueReceiver

readTransaction

protected QueuePullTransaction readTransaction

transaction

protected QueuePullTransaction transaction

Constructor Details

Consumer

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

Throws:

Exception

Method Details

createReceiver

protected QueueReceiver createReceiver(int subscriptionId)
                                throws Exception

Throws:

Exception

createTransaction

public QueuePullTransaction createTransaction()
                                       throws Exception

Throws:

Exception

createReadTransaction

public QueuePullTransaction createReadTransaction()
                                           throws Exception

Throws:

Exception

start

public void start(MessageProcessor messageProcessor)
           throws Exception

Throws:

Exception

restart

public void restart()
             throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

close

public void close()

toString

public String toString()

Overrides:

toString in class Object