1 21 package com.presumo.jms.client; 22 23 import javax.jms.QueueConnectionFactory ; 24 import javax.jms.QueueConnection ; 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 JmsQueueConnectionFactory extends JmsConnectionFactory 37 implements QueueConnectionFactory 38 { 39 40 41 45 public JmsQueueConnectionFactory() 46 { 47 } 48 49 53 public QueueConnection createQueueConnection() throws JMSException 54 { 55 logger.entry("createQueueConnection"); 56 57 QueueConnection retval = null; 58 59 Router r = getRouter(); 60 if (host == null) { 61 retval = new JmsQueueConnection(r); 62 } else { 63 retval = new JmsQueueConnection(r, host, port); 64 } 65 66 logger.exit("createQueueConnection"); 67 return retval; 68 69 } 70 71 78 public QueueConnection createQueueConnection(String userName, String password) 79 throws JMSException 80 { 81 return createQueueConnection(); 82 } 83 84 private static Logger logger = LoggerFactory.getLogger 86 (JmsQueueConnectionFactory.class, Resources.getBundle()); 87 89 } 90 91 | Popular Tags |