1 21 package com.presumo.jms.client; 22 23 import javax.jms.TopicConnectionFactory ; 24 import javax.jms.TopicConnection ; 25 import javax.jms.JMSException ; 26 27 import com.presumo.jms.resources.Resources; 28 import com.presumo.jms.router.Router; 29 import com.presumo.util.log.Logger; 30 import com.presumo.util.log.LoggerFactory; 31 32 36 public class JmsTopicConnectionFactory extends JmsConnectionFactory 37 implements TopicConnectionFactory  38 { 39 40 41 45 public JmsTopicConnectionFactory() 46 { 47 } 48 49 53 public TopicConnection createTopicConnection() throws JMSException  54 { 55 logger.entry("createTopicConnection"); 56 57 TopicConnection retval = null; 58 59 Router r = getRouter(); 60 if (host == null) { 61 retval = new JmsTopicConnection(r); 62 } else { 63 retval = new JmsTopicConnection(r, host, port); 64 } 65 66 logger.exit("createTopicConnection"); 67 return retval; 68 69 } 70 71 78 public TopicConnection createTopicConnection(String userName, String password) 79 throws JMSException  80 { 81 return createTopicConnection(); 82 } 83 84 85 private static Logger logger = LoggerFactory.getLogger 87 (JmsTopicConnectionFactory.class, Resources.getBundle()); 88 90 } 91 92 | Popular Tags |