1 46 package org.mr.api.jms; 47 import javax.jms.*; 48 49 50 import java.io.Serializable ; 51 64 public class MantaQueueConnectionFactory extends MantaConnectionFactory implements Serializable , QueueConnectionFactory { 65 66 67 71 public MantaQueueConnectionFactory() { 72 this(MantaConnection.JMS_AGENT_NAME); 73 } 74 75 79 public MantaQueueConnectionFactory(String s) { 80 this.name = s; 81 } 82 83 86 public QueueConnection createQueueConnection() 87 throws JMSException 88 { 89 return this.createQueueConnection(null, null); 90 } 91 92 95 public QueueConnection createQueueConnection (String userName, String password) throws JMSException{ 96 97 MantaQueueConnection cc = null; 98 cc = new MantaQueueConnection(this,userName,password); 99 addNewConnection(cc); 100 return cc; 101 }} | Popular Tags |