Package org.ow2.joram.jakarta.jms

Class XAJMSContext

  • All Implemented Interfaces:
    jakarta.jms.JMSContext, jakarta.jms.XAJMSContext, AutoCloseable
    public class XAJMSContext
extends Object
implements jakarta.jms.XAJMSContext

    • Field Detail

      • context

        private JMSContext context
        Embedded JMSContext object associated with this XAJMSContext.

      • xaResource

        private XAResource xaResource
        The XA resource representing the session to the transaction manager.

    • Constructor Detail

      • XAJMSContext

        public XAJMSContext​(XAConnection cnx)
        Creates a new Context using a newly created JMS connection.
        Parameters:
        connection - the created JMS connection.

    • Method Detail

      • createContext

        public jakarta.jms.JMSContext createContext​(int sessionMode)
        Specified by:
        createContext in interface jakarta.jms.JMSContext

      • createProducer

        public jakarta.jms.JMSProducer createProducer()
        Specified by:
        createProducer in interface jakarta.jms.JMSContext

      • getClientID

        public String getClientID()
        Specified by:
        getClientID in interface jakarta.jms.JMSContext

      • setClientID

        public void setClientID​(String clientID)
        Specified by:
        setClientID in interface jakarta.jms.JMSContext

      • getMetaData

        public jakarta.jms.ConnectionMetaData getMetaData()
        Specified by:
        getMetaData in interface jakarta.jms.JMSContext

      • getExceptionListener

        public jakarta.jms.ExceptionListener getExceptionListener()
        Specified by:
        getExceptionListener in interface jakarta.jms.JMSContext

      • setExceptionListener

        public void setExceptionListener​(jakarta.jms.ExceptionListener listener)
        Specified by:
        setExceptionListener in interface jakarta.jms.JMSContext

      • start

        public void start()
        Specified by:
        start in interface jakarta.jms.JMSContext

      • stop

        public void stop()
        Specified by:
        stop in interface jakarta.jms.JMSContext

      • setAutoStart

        public void setAutoStart​(boolean autoStart)
        Specified by:
        setAutoStart in interface jakarta.jms.JMSContext

      • getAutoStart

        public boolean getAutoStart()
        Specified by:
        getAutoStart in interface jakarta.jms.JMSContext

      • close

        public void close()
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface jakarta.jms.JMSContext

      • createBytesMessage

        public jakarta.jms.BytesMessage createBytesMessage()
        Specified by:
        createBytesMessage in interface jakarta.jms.JMSContext

      • createMapMessage

        public jakarta.jms.MapMessage createMapMessage()
        Specified by:
        createMapMessage in interface jakarta.jms.JMSContext

      • createMessage

        public jakarta.jms.Message createMessage()
        Specified by:
        createMessage in interface jakarta.jms.JMSContext

      • createObjectMessage

        public jakarta.jms.ObjectMessage createObjectMessage()
        Specified by:
        createObjectMessage in interface jakarta.jms.JMSContext

      • createObjectMessage

        public jakarta.jms.ObjectMessage createObjectMessage​(Serializable object)
        Specified by:
        createObjectMessage in interface jakarta.jms.JMSContext

      • createStreamMessage

        public jakarta.jms.StreamMessage createStreamMessage()
        Specified by:
        createStreamMessage in interface jakarta.jms.JMSContext

      • createTextMessage

        public jakarta.jms.TextMessage createTextMessage()
        Specified by:
        createTextMessage in interface jakarta.jms.JMSContext

      • createTextMessage

        public jakarta.jms.TextMessage createTextMessage​(String text)
        Specified by:
        createTextMessage in interface jakarta.jms.JMSContext

      • getSessionMode

        public int getSessionMode()
        Specified by:
        getSessionMode in interface jakarta.jms.JMSContext

      • recover

        public void recover()
        Specified by:
        recover in interface jakarta.jms.JMSContext

      • createConsumer

        public jakarta.jms.JMSConsumer createConsumer​(jakarta.jms.Destination destination)
        Specified by:
        createConsumer in interface jakarta.jms.JMSContext

      • createConsumer

        public jakarta.jms.JMSConsumer createConsumer​(jakarta.jms.Destination destination,
                                              String selector)
        Specified by:
        createConsumer in interface jakarta.jms.JMSContext

      • createConsumer

        public jakarta.jms.JMSConsumer createConsumer​(jakarta.jms.Destination destination,
                                              String selector,
                                              boolean noLocal)
        Specified by:
        createConsumer in interface jakarta.jms.JMSContext

      • createQueue

        public jakarta.jms.Queue createQueue​(String name)
        Specified by:
        createQueue in interface jakarta.jms.JMSContext

      • createTopic

        public jakarta.jms.Topic createTopic​(String name)
        Specified by:
        createTopic in interface jakarta.jms.JMSContext

      • createDurableConsumer

        public jakarta.jms.JMSConsumer createDurableConsumer​(jakarta.jms.Topic topic,
                                                     String name)
        Specified by:
        createDurableConsumer in interface jakarta.jms.JMSContext

      • createDurableConsumer

        public jakarta.jms.JMSConsumer createDurableConsumer​(jakarta.jms.Topic topic,
                                                     String name,
                                                     String selector,
                                                     boolean noLocal)
        Specified by:
        createDurableConsumer in interface jakarta.jms.JMSContext

      • createSharedDurableConsumer

        public jakarta.jms.JMSConsumer createSharedDurableConsumer​(jakarta.jms.Topic topic,
                                                           String name)
        Specified by:
        createSharedDurableConsumer in interface jakarta.jms.JMSContext

      • createSharedDurableConsumer

        public jakarta.jms.JMSConsumer createSharedDurableConsumer​(jakarta.jms.Topic topic,
                                                           String name,
                                                           String selector)
        Specified by:
        createSharedDurableConsumer in interface jakarta.jms.JMSContext

      • createSharedConsumer

        public jakarta.jms.JMSConsumer createSharedConsumer​(jakarta.jms.Topic topic,
                                                    String name)
        Specified by:
        createSharedConsumer in interface jakarta.jms.JMSContext

      • createSharedConsumer

        public jakarta.jms.JMSConsumer createSharedConsumer​(jakarta.jms.Topic topic,
                                                    String name,
                                                    String selector)
        Specified by:
        createSharedConsumer in interface jakarta.jms.JMSContext

      • createBrowser

        public jakarta.jms.QueueBrowser createBrowser​(jakarta.jms.Queue queue)
        Specified by:
        createBrowser in interface jakarta.jms.JMSContext

      • createBrowser

        public jakarta.jms.QueueBrowser createBrowser​(jakarta.jms.Queue queue,
                                              String selector)
        Specified by:
        createBrowser in interface jakarta.jms.JMSContext

      • createTemporaryQueue

        public jakarta.jms.TemporaryQueue createTemporaryQueue()
        Specified by:
        createTemporaryQueue in interface jakarta.jms.JMSContext

      • createTemporaryTopic

        public jakarta.jms.TemporaryTopic createTemporaryTopic()
        Specified by:
        createTemporaryTopic in interface jakarta.jms.JMSContext

      • unsubscribe

        public void unsubscribe​(String name)
        Specified by:
        unsubscribe in interface jakarta.jms.JMSContext

      • acknowledge

        public void acknowledge()
        Specified by:
        acknowledge in interface jakarta.jms.JMSContext

      • getContext

        public jakarta.jms.JMSContext getContext()
        Specified by:
        getContext in interface jakarta.jms.XAJMSContext

      • getXAResource

        public XAResource getXAResource()
        Specified by:
        getXAResource in interface jakarta.jms.XAJMSContext

      • getTransacted

        public boolean getTransacted()
        Specified by:
        getTransacted in interface jakarta.jms.JMSContext
        Specified by:
        getTransacted in interface jakarta.jms.XAJMSContext

      • commit

        public void commit()
        Specified by:
        commit in interface jakarta.jms.JMSContext
        Specified by:
        commit in interface jakarta.jms.XAJMSContext

      • rollback

        public void rollback()
        Specified by:
        rollback in interface jakarta.jms.JMSContext
        Specified by:
        rollback in interface jakarta.jms.XAJMSContext