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

Class Consumer

java.lang.Object

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

All Implemented Interfaces:

TransactionFactory

Direct Known Subclasses:

QueueConsumer, TopicConsumer, TopicDurableConsumer

public class Consumer
extends Object
implements TransactionFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected int	clientDispatchId
protected int	clientListenerId
protected SessionContext	ctx
protected boolean	hasListener
protected boolean	markedForClose
protected com.swiftmq.swiftlet.queue.MessageProcessor	messageProcessor
protected com.swiftmq.swiftlet.queue.QueuePullTransaction	readTransaction
protected com.swiftmq.swiftlet.queue.QueueReceiver	receiver
protected com.swiftmq.swiftlet.queue.Selector	selector
protected com.swiftmq.swiftlet.queue.QueuePullTransaction	transaction

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Consumer(SessionContext ctx)

Method Summary

Modifier and Type	Method	Description
protected void	close()
com.swiftmq.swiftlet.queue.QueueTransaction	createDuplicateTransaction()
com.swiftmq.swiftlet.queue.QueueTransaction	createReadTransaction()
com.swiftmq.swiftlet.queue.QueueTransaction	createTransaction()
int	getClientDispatchId()
int	getClientListenerId()
com.swiftmq.swiftlet.queue.MessageProcessor	getMessageProcessor()
com.swiftmq.swiftlet.queue.QueuePullTransaction	getReadTransaction()
com.swiftmq.swiftlet.queue.Selector	getSelector()
com.swiftmq.swiftlet.queue.QueuePullTransaction	getTransaction()
boolean	hasListener()
protected boolean	isAutoCommit()
boolean	isMarkedForClose()
void	markForClose()
void	removeMessageListener()
void	setMessageListener(int clientDispatchId, int clientListenerId, com.swiftmq.swiftlet.queue.MessageProcessor messageProcessor)
protected void	setQueueReceiver(com.swiftmq.swiftlet.queue.QueueReceiver receiver)
protected void	setSelector(com.swiftmq.swiftlet.queue.Selector selector)

Methods inherited from class java.lang.Object

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

Field Details

ctx

protected SessionContext ctx

receiver

protected com.swiftmq.swiftlet.queue.QueueReceiver receiver

selector

protected com.swiftmq.swiftlet.queue.Selector selector

readTransaction

protected com.swiftmq.swiftlet.queue.QueuePullTransaction readTransaction

transaction

protected com.swiftmq.swiftlet.queue.QueuePullTransaction transaction

clientDispatchId

protected int clientDispatchId

clientListenerId

protected int clientListenerId

messageProcessor

protected com.swiftmq.swiftlet.queue.MessageProcessor messageProcessor

hasListener

protected boolean hasListener

markedForClose

protected boolean markedForClose

Constructor Details

Consumer

protected Consumer(SessionContext ctx)

Method Details

isAutoCommit

protected boolean isAutoCommit()

setQueueReceiver

protected void setQueueReceiver(com.swiftmq.swiftlet.queue.QueueReceiver receiver)

setSelector

protected void setSelector(com.swiftmq.swiftlet.queue.Selector selector)

getSelector

public com.swiftmq.swiftlet.queue.Selector getSelector()

createTransaction

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

Specified by:

createTransaction in interface TransactionFactory

Throws:

Exception

createReadTransaction

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

Throws:

Exception

getTransaction

public com.swiftmq.swiftlet.queue.QueuePullTransaction getTransaction()

getReadTransaction

public com.swiftmq.swiftlet.queue.QueuePullTransaction getReadTransaction()

createDuplicateTransaction

public com.swiftmq.swiftlet.queue.QueueTransaction createDuplicateTransaction()
                                                                       throws Exception

Throws:

Exception

setMessageListener

public void setMessageListener(int clientDispatchId,
 int clientListenerId,
 com.swiftmq.swiftlet.queue.MessageProcessor messageProcessor)

getClientDispatchId

public int getClientDispatchId()

getClientListenerId

public int getClientListenerId()

getMessageProcessor

public com.swiftmq.swiftlet.queue.MessageProcessor getMessageProcessor()

removeMessageListener

public void removeMessageListener()

hasListener

public boolean hasListener()

markForClose

public void markForClose()

Specified by:

markForClose in interface TransactionFactory

isMarkedForClose

public boolean isMarkedForClose()

Specified by:

isMarkedForClose in interface TransactionFactory

close

protected void close()
              throws Exception

Throws:

Exception