Package com.swiftmq.impl.jms.standard.v750

Class TopicConsumer

java.lang.Object

com.swiftmq.impl.jms.standard.v750.Consumer

com.swiftmq.impl.jms.standard.v750.TopicConsumer

All Implemented Interfaces:

TransactionFactory

public class TopicConsumer
extends Consumer

Field Summary

Fields

Modifier and Type	Field	Description
protected String	queueName
protected int	subscriberId
protected TopicImpl	topic
protected TopicManager	topicManager
protected String	topicName

Fields inherited from class com.swiftmq.impl.jms.standard.v750.Consumer

clientDispatchId, clientListenerId, ctx, hasListener, markedForClose, messageProcessor, readTransaction, receiver, selector, transaction

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TopicConsumer(SessionContext ctx, TopicImpl topic, String selector, boolean noLocal)

Method Summary

Modifier and Type	Method	Description
protected void	close()
String	getQueueName()
protected boolean	isAutoCommit()
protected void	setAutoCommit(boolean autoCommit)
String	toString()

Methods inherited from class com.swiftmq.impl.jms.standard.v750.Consumer

createDuplicateTransaction, createReadTransaction, createTransaction, getClientDispatchId, getClientListenerId, getMessageProcessor, getReadTransaction, getSelector, getTransaction, hasListener, isMarkedForClose, markForClose, removeMessageListener, setMessageListener, setQueueReceiver, setSelector

Methods inherited from class java.lang.Object

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

Field Details

topicManager

protected TopicManager topicManager

topic

protected TopicImpl topic

subscriberId

protected int subscriberId

queueName

protected String queueName

topicName

protected String topicName

Constructor Details

TopicConsumer

protected TopicConsumer(SessionContext ctx,
 TopicImpl topic,
 String selector,
 boolean noLocal)
                 throws Exception

Throws:

Exception

Method Details

getQueueName

public String getQueueName()

isAutoCommit

protected boolean isAutoCommit()

Overrides:

isAutoCommit in class Consumer

setAutoCommit

protected void setAutoCommit(boolean autoCommit)

close

protected void close()
              throws Exception

Overrides:

close in class Consumer

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object