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