1 48 package org.exolab.jms.client; 49 50 import javax.jms.JMSException ; 51 import javax.jms.QueueSession ; 52 import javax.jms.XAQueueConnection ; 53 import javax.jms.XAQueueSession ; 54 import javax.jms.XASession ; 55 56 57 65 public class JmsXAQueueConnection 66 extends JmsQueueConnection 67 implements XAQueueConnection { 68 69 78 public JmsXAQueueConnection(JmsXAConnectionFactory factory, String id, 79 String username, String password) 80 throws JMSException { 81 super(factory, id, username, password); 82 } 83 84 92 public XASession createXASession() throws JMSException { 93 return new JmsXASession(this); 94 } 95 96 104 public XAQueueSession createXAQueueSession() throws JMSException { 105 ensureOpen(); 106 setModified(); 107 return new JmsXAQueueSession(this); 108 } 109 110 120 public QueueSession createQueueSession(boolean transacted, 121 int acknowledgeMode) 122 throws JMSException { 123 124 ensureOpen(); 125 setModified(); 126 return new JmsXAQueueSession(this); 127 } 128 129 } 130 | Popular Tags |