1 28 29 package com.caucho.jms; 30 31 import com.caucho.jms.session.TopicConnectionImpl; 32 33 import javax.jms.JMSException ; 34 import javax.jms.TopicConnection ; 35 import javax.jms.TopicConnectionFactory ; 36 37 40 public class JVMTopicConnectionFactory extends ConnectionFactoryImpl 41 implements TopicConnectionFactory { 42 public JVMTopicConnectionFactory() 43 { 44 } 45 46 49 public TopicConnection createTopicConnection() 50 throws JMSException 51 { 52 return createTopicConnection(null, null); 53 } 54 55 63 public TopicConnection createTopicConnection(String username, 64 String password) 65 throws JMSException 66 { 67 authenticate(username, password); 68 69 TopicConnectionImpl conn = new TopicConnectionImpl(this); 70 71 addConnection(conn); 72 73 return conn; 74 } 75 } 76 | Popular Tags |