Package com.swiftmq.impl.jms.standard.v630

Class TopicConsumer

java.lang.Object

com.swiftmq.impl.jms.standard.v630.Consumer

com.swiftmq.impl.jms.standard.v630.TopicConsumer

All Implemented Interfaces:

TransactionFactory

public class TopicConsumer
extends Consumer

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.String	queueName
protected int	subscriberId
protected TopicImpl	topic
protected TopicManager	topicManager

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

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class com.swiftmq.impl.jms.standard.v630.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 Detail

topicManager

protected TopicManager topicManager

topic

protected TopicImpl topic

subscriberId

protected int subscriberId

queueName

protected java.lang.String queueName

Constructor Detail

TopicConsumer

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

Throws:

java.lang.Exception

Method Detail

getQueueName

public java.lang.String getQueueName()

isAutoCommit

protected boolean isAutoCommit()

Overrides:

isAutoCommit in class Consumer

setAutoCommit

protected void setAutoCommit(boolean autoCommit)

close

protected void close()
              throws java.lang.Exception

Overrides:

close in class Consumer

Throws:

java.lang.Exception

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object