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 com.swiftmq.swiftlet.queue.QueueReceiver	queueReceiver
protected com.swiftmq.swiftlet.queue.QueuePullTransaction	readTransaction
protected com.swiftmq.swiftlet.queue.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()
com.swiftmq.swiftlet.queue.QueuePullTransaction	createReadTransaction()
protected com.swiftmq.swiftlet.queue.QueueReceiver	createReceiver(int subscriptionId)
com.swiftmq.swiftlet.queue.QueuePullTransaction	createTransaction()
void	restart()
void	start(com.swiftmq.swiftlet.queue.MessageProcessor messageProcessor)
void	stop()
String	toString()

Methods inherited from class Object

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

Field Details

queueReceiver

protected com.swiftmq.swiftlet.queue.QueueReceiver queueReceiver

readTransaction

protected com.swiftmq.swiftlet.queue.QueuePullTransaction readTransaction

transaction

protected com.swiftmq.swiftlet.queue.QueuePullTransaction transaction

Constructor Details

Consumer

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

Throws:

Exception

Method Details

createReceiver

protected com.swiftmq.swiftlet.queue.QueueReceiver createReceiver(int subscriptionId)
                                                           throws Exception

Throws:

Exception

createTransaction

public com.swiftmq.swiftlet.queue.QueuePullTransaction createTransaction()
                                                                  throws Exception

Throws:

Exception

createReadTransaction

public com.swiftmq.swiftlet.queue.QueuePullTransaction createReadTransaction()
                                                                      throws Exception

Throws:

Exception

start

public void start(com.swiftmq.swiftlet.queue.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