Class Producer
- java.lang.Object
-
- com.swiftmq.impl.jms.standard.v400.Producer
-
- All Implemented Interfaces:
TransactionFactory
- Direct Known Subclasses:
QueueProducer
,TopicProducer
public class Producer extends java.lang.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
QueueTransaction
createTransaction()
QueuePushTransaction
getTransaction()
boolean
isMarkedForClose()
void
markForClose()
protected void
setQueueSender(QueueSender sender)
-
-
-
Field Detail
-
ctx
protected SessionContext ctx
-
sender
protected QueueSender sender
-
transaction
protected QueuePushTransaction transaction
-
markedForClose
protected boolean markedForClose
-
-
Constructor Detail
-
Producer
protected Producer(SessionContext ctx)
-
-
Method Detail
-
setQueueSender
protected void setQueueSender(QueueSender sender)
-
createTransaction
public QueueTransaction createTransaction() throws java.lang.Exception
- Specified by:
createTransaction
in interfaceTransactionFactory
- Returns:
- Throws:
java.lang.Exception
-
getTransaction
public QueuePushTransaction getTransaction()
-
markForClose
public void markForClose()
- Specified by:
markForClose
in interfaceTransactionFactory
-
isMarkedForClose
public boolean isMarkedForClose()
- Specified by:
isMarkedForClose
in interfaceTransactionFactory
-
close
public void close() throws java.lang.Exception
- Throws:
java.lang.Exception
-
-