1 45 package org.exolab.jms.client; 46 47 import javax.jms.JMSException ; 48 import javax.jms.TopicSession ; 49 import javax.jms.XASession ; 50 import javax.jms.XATopicConnection ; 51 import javax.jms.XATopicSession ; 52 53 54 62 public class JmsXATopicConnection 63 extends JmsTopicConnection 64 implements XATopicConnection { 65 66 75 public JmsXATopicConnection(JmsXAConnectionFactory factory, String id, 76 String username, String password) 77 throws JMSException { 78 super(factory, id, username, password); 79 } 80 81 89 public XASession createXASession() throws JMSException { 90 return new JmsXASession(this); 91 } 92 93 101 public XATopicSession createXATopicSession() throws JMSException { 102 ensureOpen(); 103 setModified(); 104 return new JmsXATopicSession(this); 105 } 106 107 117 public TopicSession createTopicSession(boolean transacted, 118 int acknowledgeMode) 119 throws JMSException { 120 121 ensureOpen(); 122 setModified(); 123 return new JmsXATopicSession(this); 124 } 125 } | Popular Tags |