1 46 package org.mr.api.jms; 47 48 import java.io.Serializable ; 49 50 import javax.jms.JMSException ; 51 import javax.jms.TopicConnection ; 52 import javax.jms.TopicConnectionFactory ; 53 54 68 public class MantaTopicConnectionFactory extends MantaConnectionFactory implements Serializable , 69 TopicConnectionFactory { 70 71 77 public MantaTopicConnectionFactory() { 78 this("MantaRay"); 79 80 } 81 82 83 89 public MantaTopicConnectionFactory(String s) { 90 this.name = s; 91 } 92 93 96 public TopicConnection createTopicConnection() throws JMSException { 97 return createTopicConnection("unknown","unknown"); 98 } 99 100 104 public TopicConnection createTopicConnection (String userName, String password) throws JMSException { 105 106 MantaTopicConnection ctc = null; 107 ctc = new MantaTopicConnection(this,userName,password); 108 addNewConnection(ctc); 109 return ctc; 110 111 112 }} | Popular Tags |