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

Class Producer

java.lang.Object

com.swiftmq.impl.jms.standard.v750.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 QueueSender	sender
protected QueuePushTransaction	transaction

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Producer(SessionContext ctx)

Method Summary

Modifier and Type	Method	Description
void	close()
QueueTransaction	createTransaction()
QueuePushTransaction	getTransaction()
boolean	isMarkedForClose()
void	markForClose()
protected void	setQueueSender(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 QueueSender sender

transaction

protected QueuePushTransaction transaction

markedForClose

protected boolean markedForClose

Constructor Details

Producer

protected Producer(SessionContext ctx)

Method Details

setQueueSender

protected void setQueueSender(QueueSender sender)

createTransaction

public QueueTransaction createTransaction()
                                   throws Exception

Specified by:

createTransaction in interface TransactionFactory

Throws:

Exception

getTransaction

public 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