Package org.jboss.narayana.jta.jms
Class JMSContextProxy
java.lang.Object
org.jboss.narayana.jta.jms.JMSContextProxy
- All Implemented Interfaces:
jakarta.jms.JMSContext
,AutoCloseable
-
Field Summary
Fields inherited from interface jakarta.jms.JMSContext
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
-
Method Summary
Modifier and TypeMethodDescriptionvoid
void
close()
void
commit()
jakarta.jms.QueueBrowser
createBrowser
(jakarta.jms.Queue queue) jakarta.jms.QueueBrowser
createBrowser
(jakarta.jms.Queue queue, String s) jakarta.jms.BytesMessage
jakarta.jms.JMSConsumer
createConsumer
(jakarta.jms.Destination destination) jakarta.jms.JMSConsumer
createConsumer
(jakarta.jms.Destination destination, String s) jakarta.jms.JMSConsumer
createConsumer
(jakarta.jms.Destination destination, String s, boolean b) jakarta.jms.JMSContext
createContext
(int i) jakarta.jms.JMSConsumer
createDurableConsumer
(jakarta.jms.Topic topic, String s) jakarta.jms.JMSConsumer
createDurableConsumer
(jakarta.jms.Topic topic, String s, String s1, boolean b) jakarta.jms.MapMessage
jakarta.jms.Message
jakarta.jms.ObjectMessage
jakarta.jms.ObjectMessage
createObjectMessage
(Serializable serializable) jakarta.jms.JMSProducer
jakarta.jms.Queue
jakarta.jms.JMSConsumer
createSharedConsumer
(jakarta.jms.Topic topic, String s) jakarta.jms.JMSConsumer
createSharedConsumer
(jakarta.jms.Topic topic, String s, String s1) jakarta.jms.JMSConsumer
createSharedDurableConsumer
(jakarta.jms.Topic topic, String s) jakarta.jms.JMSConsumer
createSharedDurableConsumer
(jakarta.jms.Topic topic, String s, String s1) jakarta.jms.StreamMessage
jakarta.jms.TemporaryQueue
jakarta.jms.TemporaryTopic
jakarta.jms.TextMessage
jakarta.jms.TextMessage
jakarta.jms.Topic
boolean
jakarta.jms.ExceptionListener
jakarta.jms.ConnectionMetaData
int
boolean
void
recover()
void
rollback()
void
setAutoStart
(boolean b) void
void
setExceptionListener
(jakarta.jms.ExceptionListener exceptionListener) void
start()
void
stop()
void
static jakarta.jms.JMSContext
wrapContext
(jakarta.jms.XAJMSContext xaContext, TransactionHelper transactionHelper)
-
Method Details
-
wrapContext
public static jakarta.jms.JMSContext wrapContext(jakarta.jms.XAJMSContext xaContext, TransactionHelper transactionHelper) -
createContext
public jakarta.jms.JMSContext createContext(int i) - Specified by:
createContext
in interfacejakarta.jms.JMSContext
-
createProducer
public jakarta.jms.JMSProducer createProducer()- Specified by:
createProducer
in interfacejakarta.jms.JMSContext
-
getClientID
- Specified by:
getClientID
in interfacejakarta.jms.JMSContext
-
setClientID
- Specified by:
setClientID
in interfacejakarta.jms.JMSContext
-
getMetaData
public jakarta.jms.ConnectionMetaData getMetaData()- Specified by:
getMetaData
in interfacejakarta.jms.JMSContext
-
getExceptionListener
public jakarta.jms.ExceptionListener getExceptionListener()- Specified by:
getExceptionListener
in interfacejakarta.jms.JMSContext
-
setExceptionListener
public void setExceptionListener(jakarta.jms.ExceptionListener exceptionListener) - Specified by:
setExceptionListener
in interfacejakarta.jms.JMSContext
-
start
public void start()- Specified by:
start
in interfacejakarta.jms.JMSContext
-
stop
public void stop()- Specified by:
stop
in interfacejakarta.jms.JMSContext
-
setAutoStart
public void setAutoStart(boolean b) - Specified by:
setAutoStart
in interfacejakarta.jms.JMSContext
-
getAutoStart
public boolean getAutoStart()- Specified by:
getAutoStart
in interfacejakarta.jms.JMSContext
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfacejakarta.jms.JMSContext
-
createBytesMessage
public jakarta.jms.BytesMessage createBytesMessage()- Specified by:
createBytesMessage
in interfacejakarta.jms.JMSContext
-
createMapMessage
public jakarta.jms.MapMessage createMapMessage()- Specified by:
createMapMessage
in interfacejakarta.jms.JMSContext
-
createMessage
public jakarta.jms.Message createMessage()- Specified by:
createMessage
in interfacejakarta.jms.JMSContext
-
createObjectMessage
public jakarta.jms.ObjectMessage createObjectMessage()- Specified by:
createObjectMessage
in interfacejakarta.jms.JMSContext
-
createObjectMessage
- Specified by:
createObjectMessage
in interfacejakarta.jms.JMSContext
-
createStreamMessage
public jakarta.jms.StreamMessage createStreamMessage()- Specified by:
createStreamMessage
in interfacejakarta.jms.JMSContext
-
createTextMessage
public jakarta.jms.TextMessage createTextMessage()- Specified by:
createTextMessage
in interfacejakarta.jms.JMSContext
-
createTextMessage
- Specified by:
createTextMessage
in interfacejakarta.jms.JMSContext
-
getTransacted
public boolean getTransacted()- Specified by:
getTransacted
in interfacejakarta.jms.JMSContext
-
getSessionMode
public int getSessionMode()- Specified by:
getSessionMode
in interfacejakarta.jms.JMSContext
-
commit
public void commit()- Specified by:
commit
in interfacejakarta.jms.JMSContext
-
rollback
public void rollback()- Specified by:
rollback
in interfacejakarta.jms.JMSContext
-
recover
public void recover()- Specified by:
recover
in interfacejakarta.jms.JMSContext
-
createConsumer
public jakarta.jms.JMSConsumer createConsumer(jakarta.jms.Destination destination) - Specified by:
createConsumer
in interfacejakarta.jms.JMSContext
-
createConsumer
- Specified by:
createConsumer
in interfacejakarta.jms.JMSContext
-
createConsumer
public jakarta.jms.JMSConsumer createConsumer(jakarta.jms.Destination destination, String s, boolean b) - Specified by:
createConsumer
in interfacejakarta.jms.JMSContext
-
createQueue
- Specified by:
createQueue
in interfacejakarta.jms.JMSContext
-
createTopic
- Specified by:
createTopic
in interfacejakarta.jms.JMSContext
-
createDurableConsumer
- Specified by:
createDurableConsumer
in interfacejakarta.jms.JMSContext
-
createDurableConsumer
public jakarta.jms.JMSConsumer createDurableConsumer(jakarta.jms.Topic topic, String s, String s1, boolean b) - Specified by:
createDurableConsumer
in interfacejakarta.jms.JMSContext
-
createBrowser
public jakarta.jms.QueueBrowser createBrowser(jakarta.jms.Queue queue) - Specified by:
createBrowser
in interfacejakarta.jms.JMSContext
-
createBrowser
- Specified by:
createBrowser
in interfacejakarta.jms.JMSContext
-
createTemporaryQueue
public jakarta.jms.TemporaryQueue createTemporaryQueue()- Specified by:
createTemporaryQueue
in interfacejakarta.jms.JMSContext
-
createTemporaryTopic
public jakarta.jms.TemporaryTopic createTemporaryTopic()- Specified by:
createTemporaryTopic
in interfacejakarta.jms.JMSContext
-
unsubscribe
- Specified by:
unsubscribe
in interfacejakarta.jms.JMSContext
-
acknowledge
public void acknowledge()- Specified by:
acknowledge
in interfacejakarta.jms.JMSContext
-