public class XAJMSContext extends Object implements jakarta.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() |
jakarta.jms.QueueBrowser |
createBrowser(jakarta.jms.Queue queue) |
jakarta.jms.QueueBrowser |
createBrowser(jakarta.jms.Queue queue,
String selector) |
jakarta.jms.BytesMessage |
createBytesMessage() |
jakarta.jms.JMSConsumer |
createConsumer(jakarta.jms.Destination destination) |
jakarta.jms.JMSConsumer |
createConsumer(jakarta.jms.Destination destination,
String selector) |
jakarta.jms.JMSConsumer |
createConsumer(jakarta.jms.Destination destination,
String selector,
boolean noLocal) |
jakarta.jms.JMSContext |
createContext(int sessionMode) |
jakarta.jms.JMSConsumer |
createDurableConsumer(jakarta.jms.Topic topic,
String name) |
jakarta.jms.JMSConsumer |
createDurableConsumer(jakarta.jms.Topic topic,
String name,
String selector,
boolean noLocal) |
jakarta.jms.MapMessage |
createMapMessage() |
jakarta.jms.Message |
createMessage() |
jakarta.jms.ObjectMessage |
createObjectMessage() |
jakarta.jms.ObjectMessage |
createObjectMessage(Serializable object) |
jakarta.jms.JMSProducer |
createProducer() |
jakarta.jms.Queue |
createQueue(String name) |
jakarta.jms.JMSConsumer |
createSharedConsumer(jakarta.jms.Topic topic,
String name) |
jakarta.jms.JMSConsumer |
createSharedConsumer(jakarta.jms.Topic topic,
String name,
String selector) |
jakarta.jms.JMSConsumer |
createSharedDurableConsumer(jakarta.jms.Topic topic,
String name) |
jakarta.jms.JMSConsumer |
createSharedDurableConsumer(jakarta.jms.Topic topic,
String name,
String selector) |
jakarta.jms.StreamMessage |
createStreamMessage() |
jakarta.jms.TemporaryQueue |
createTemporaryQueue() |
jakarta.jms.TemporaryTopic |
createTemporaryTopic() |
jakarta.jms.TextMessage |
createTextMessage() |
jakarta.jms.TextMessage |
createTextMessage(String text) |
jakarta.jms.Topic |
createTopic(String name) |
boolean |
getAutoStart() |
String |
getClientID() |
jakarta.jms.JMSContext |
getContext() |
jakarta.jms.ExceptionListener |
getExceptionListener() |
jakarta.jms.ConnectionMetaData |
getMetaData() |
int |
getSessionMode() |
boolean |
getTransacted() |
XAResource |
getXAResource() |
void |
recover() |
void |
rollback() |
void |
setAutoStart(boolean autoStart) |
void |
setClientID(String clientID) |
void |
setExceptionListener(jakarta.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 jakarta.jms.JMSContext createContext(int sessionMode)
createContext
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSProducer createProducer()
createProducer
in interface jakarta.jms.JMSContext
public String getClientID()
getClientID
in interface jakarta.jms.JMSContext
public void setClientID(String clientID)
setClientID
in interface jakarta.jms.JMSContext
public jakarta.jms.ConnectionMetaData getMetaData()
getMetaData
in interface jakarta.jms.JMSContext
public jakarta.jms.ExceptionListener getExceptionListener()
getExceptionListener
in interface jakarta.jms.JMSContext
public void setExceptionListener(jakarta.jms.ExceptionListener listener)
setExceptionListener
in interface jakarta.jms.JMSContext
public void start()
start
in interface jakarta.jms.JMSContext
public void stop()
stop
in interface jakarta.jms.JMSContext
public void setAutoStart(boolean autoStart)
setAutoStart
in interface jakarta.jms.JMSContext
public boolean getAutoStart()
getAutoStart
in interface jakarta.jms.JMSContext
public void close()
close
in interface jakarta.jms.JMSContext
close
in interface AutoCloseable
public jakarta.jms.BytesMessage createBytesMessage()
createBytesMessage
in interface jakarta.jms.JMSContext
public jakarta.jms.MapMessage createMapMessage()
createMapMessage
in interface jakarta.jms.JMSContext
public jakarta.jms.Message createMessage()
createMessage
in interface jakarta.jms.JMSContext
public jakarta.jms.ObjectMessage createObjectMessage()
createObjectMessage
in interface jakarta.jms.JMSContext
public jakarta.jms.ObjectMessage createObjectMessage(Serializable object)
createObjectMessage
in interface jakarta.jms.JMSContext
public jakarta.jms.StreamMessage createStreamMessage()
createStreamMessage
in interface jakarta.jms.JMSContext
public jakarta.jms.TextMessage createTextMessage()
createTextMessage
in interface jakarta.jms.JMSContext
public jakarta.jms.TextMessage createTextMessage(String text)
createTextMessage
in interface jakarta.jms.JMSContext
public int getSessionMode()
getSessionMode
in interface jakarta.jms.JMSContext
public void recover()
recover
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createConsumer(jakarta.jms.Destination destination)
createConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createConsumer(jakarta.jms.Destination destination, String selector)
createConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createConsumer(jakarta.jms.Destination destination, String selector, boolean noLocal)
createConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.Queue createQueue(String name)
createQueue
in interface jakarta.jms.JMSContext
public jakarta.jms.Topic createTopic(String name)
createTopic
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createDurableConsumer(jakarta.jms.Topic topic, String name)
createDurableConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createDurableConsumer(jakarta.jms.Topic topic, String name, String selector, boolean noLocal)
createDurableConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createSharedDurableConsumer(jakarta.jms.Topic topic, String name)
createSharedDurableConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createSharedDurableConsumer(jakarta.jms.Topic topic, String name, String selector)
createSharedDurableConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createSharedConsumer(jakarta.jms.Topic topic, String name)
createSharedConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSConsumer createSharedConsumer(jakarta.jms.Topic topic, String name, String selector)
createSharedConsumer
in interface jakarta.jms.JMSContext
public jakarta.jms.QueueBrowser createBrowser(jakarta.jms.Queue queue)
createBrowser
in interface jakarta.jms.JMSContext
public jakarta.jms.QueueBrowser createBrowser(jakarta.jms.Queue queue, String selector)
createBrowser
in interface jakarta.jms.JMSContext
public jakarta.jms.TemporaryQueue createTemporaryQueue()
createTemporaryQueue
in interface jakarta.jms.JMSContext
public jakarta.jms.TemporaryTopic createTemporaryTopic()
createTemporaryTopic
in interface jakarta.jms.JMSContext
public void unsubscribe(String name)
unsubscribe
in interface jakarta.jms.JMSContext
public void acknowledge()
acknowledge
in interface jakarta.jms.JMSContext
public jakarta.jms.JMSContext getContext()
getContext
in interface jakarta.jms.XAJMSContext
public XAResource getXAResource()
getXAResource
in interface jakarta.jms.XAJMSContext
public boolean getTransacted()
getTransacted
in interface jakarta.jms.JMSContext
getTransacted
in interface jakarta.jms.XAJMSContext
public void commit()
commit
in interface jakarta.jms.JMSContext
commit
in interface jakarta.jms.XAJMSContext
public void rollback()
rollback
in interface jakarta.jms.JMSContext
rollback
in interface jakarta.jms.XAJMSContext
Copyright © 2023 ScalAgent D.T.. All rights reserved.