public class XAJMSContext extends Object implements XAJMSContext
Modifier and Type | Field and Description |
---|---|
private JMSContext |
context
Embedded JMSContext object associated with this XAJMSContext.
|
private XAResource |
xaResource
The XA resource representing the session to the transaction manager.
|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
XAJMSContext(XAConnection cnx)
Creates a new Context using a newly created JMS connection.
|
private JMSContext context
private XAResource xaResource
public XAJMSContext(XAConnection cnx)
connection
- the created JMS connection.public JMSContext createContext(int sessionMode)
createContext
in interface JMSContext
public JMSProducer createProducer()
createProducer
in interface JMSContext
public String getClientID()
getClientID
in interface JMSContext
public void setClientID(String clientID)
setClientID
in interface JMSContext
public ConnectionMetaData getMetaData()
getMetaData
in interface JMSContext
public ExceptionListener getExceptionListener()
getExceptionListener
in interface JMSContext
public void setExceptionListener(ExceptionListener listener)
setExceptionListener
in interface JMSContext
public void start()
start
in interface JMSContext
public void stop()
stop
in interface JMSContext
public void setAutoStart(boolean autoStart)
setAutoStart
in interface JMSContext
public boolean getAutoStart()
getAutoStart
in interface JMSContext
public void close()
close
in interface AutoCloseable
close
in interface JMSContext
public BytesMessage createBytesMessage()
createBytesMessage
in interface JMSContext
public MapMessage createMapMessage()
createMapMessage
in interface JMSContext
public Message createMessage()
createMessage
in interface JMSContext
public ObjectMessage createObjectMessage()
createObjectMessage
in interface JMSContext
public ObjectMessage createObjectMessage(Serializable object)
createObjectMessage
in interface JMSContext
public StreamMessage createStreamMessage()
createStreamMessage
in interface JMSContext
public TextMessage createTextMessage()
createTextMessage
in interface JMSContext
public TextMessage createTextMessage(String text)
createTextMessage
in interface JMSContext
public int getSessionMode()
getSessionMode
in interface JMSContext
public void recover()
recover
in interface JMSContext
public JMSConsumer createConsumer(Destination destination)
createConsumer
in interface JMSContext
public JMSConsumer createConsumer(Destination destination, String selector)
createConsumer
in interface JMSContext
public JMSConsumer createConsumer(Destination destination, String selector, boolean noLocal)
createConsumer
in interface JMSContext
public Queue createQueue(String name)
createQueue
in interface JMSContext
public Topic createTopic(String name)
createTopic
in interface JMSContext
public JMSConsumer createDurableConsumer(Topic topic, String name)
createDurableConsumer
in interface JMSContext
public JMSConsumer createDurableConsumer(Topic topic, String name, String selector, boolean noLocal)
createDurableConsumer
in interface JMSContext
public JMSConsumer createSharedDurableConsumer(Topic topic, String name)
createSharedDurableConsumer
in interface JMSContext
public JMSConsumer createSharedDurableConsumer(Topic topic, String name, String selector)
createSharedDurableConsumer
in interface JMSContext
public JMSConsumer createSharedConsumer(Topic topic, String name)
createSharedConsumer
in interface JMSContext
public JMSConsumer createSharedConsumer(Topic topic, String name, String selector)
createSharedConsumer
in interface JMSContext
public QueueBrowser createBrowser(Queue queue)
createBrowser
in interface JMSContext
public QueueBrowser createBrowser(Queue queue, String selector)
createBrowser
in interface JMSContext
public TemporaryQueue createTemporaryQueue()
createTemporaryQueue
in interface JMSContext
public TemporaryTopic createTemporaryTopic()
createTemporaryTopic
in interface JMSContext
public void unsubscribe(String name)
unsubscribe
in interface JMSContext
public void acknowledge()
acknowledge
in interface JMSContext
public JMSContext getContext()
getContext
in interface XAJMSContext
public XAResource getXAResource()
getXAResource
in interface XAJMSContext
public boolean getTransacted()
getTransacted
in interface JMSContext
getTransacted
in interface XAJMSContext
public void commit()
commit
in interface JMSContext
commit
in interface XAJMSContext
public void rollback()
rollback
in interface JMSContext
rollback
in interface XAJMSContext
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.