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

Class Producer

java.lang.Object

com.swiftmq.impl.jms.standard.v630.Producer

All Implemented Interfaces:

TransactionFactory

Direct Known Subclasses:

QueueProducer, TopicProducer

public class Producer
extends Object
implements TransactionFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected SessionContext	ctx
protected boolean	markedForClose
protected com.swiftmq.swiftlet.queue.QueueSender	sender
protected com.swiftmq.swiftlet.queue.QueuePushTransaction	transaction

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Producer(SessionContext ctx)

Method Summary

Modifier and Type	Method	Description
void	close()
com.swiftmq.swiftlet.queue.QueueTransaction	createTransaction()
com.swiftmq.swiftlet.queue.QueuePushTransaction	getTransaction()
boolean	isMarkedForClose()
void	markForClose()
protected void	setQueueSender(com.swiftmq.swiftlet.queue.QueueSender sender)

Methods inherited from class java.lang.Object

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

Field Details

ctx

protected SessionContext ctx

sender

protected com.swiftmq.swiftlet.queue.QueueSender sender

transaction

protected com.swiftmq.swiftlet.queue.QueuePushTransaction transaction

markedForClose

protected boolean markedForClose

Constructor Details

Producer

protected Producer(SessionContext ctx)

Method Details

setQueueSender

protected void setQueueSender(com.swiftmq.swiftlet.queue.QueueSender sender)

createTransaction

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

Specified by:

createTransaction in interface TransactionFactory

Returns:

Throws:

Exception

getTransaction

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

markForClose

public void markForClose()

Specified by:

markForClose in interface TransactionFactory

isMarkedForClose

public boolean isMarkedForClose()

Specified by:

isMarkedForClose in interface TransactionFactory

close

public void close()
           throws Exception

Throws:

Exception