KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > objectweb > joram > client > jms > tcp > QueueTcpConnectionFactory


1 /*
2  * JORAM: Java(TM) Open Reliable Asynchronous Messaging
3  * Copyright (C) 2004 - Bull SA
4  * Copyright (C) 2004 - ScalAgent Distributed Technologies
5  * Copyright (C) 1996 - Dyade
6  *
7  * This library is free software; you can redistribute it and/or
8  * modify it under the terms of the GNU Lesser General Public
9  * License as published by the Free Software Foundation; either
10  * version 2.1 of the License, or any later version.
11  *
12  * This library is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15  * Lesser General Public License for more details.
16  *
17  * You should have received a copy of the GNU Lesser General Public
18  * License along with this library; if not, write to the Free Software
19  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
20  * USA.
21  *
22  * Initial developer(s): Frederic Maistre (INRIA)
23  * Contributor(s): Nicolas Tachker (ScalAgent)
24  */
25 package org.objectweb.joram.client.jms.tcp;
26
27 import org.objectweb.joram.client.jms.Connection;
28 import org.objectweb.joram.client.jms.FactoryParameters;
29 import org.objectweb.joram.client.jms.QueueConnection;
30 import org.objectweb.joram.client.jms.admin.AdminModule;
31
32 import java.util.Vector JavaDoc;
33
34 import javax.naming.NamingException JavaDoc;
35
36
37 /**
38  * A <code>QueueTcpConnectionFactory</code> instance is a factory of
39  * TCP connections for PTP communication.
40  */
41 public class QueueTcpConnectionFactory
42              extends org.objectweb.joram.client.jms.QueueConnectionFactory
43 {
44   /**
45    * Constructs a <code>QueueTcpConnectionFactory</code> instance.
46    *
47    * @param host Name or IP address of the server's host.
48    * @param port Server's listening port.
49    */
50   public QueueTcpConnectionFactory(String JavaDoc host, int port)
51   {
52     super(host, port);
53   }
54
55   /**
56    * Constructs an empty <code>QueueTcpConnectionFactory</code> instance.
57    */
58   public QueueTcpConnectionFactory()
59   {}
60
61
62   /**
63    * Method inherited from the <code>QueueConnectionFactory</code> class.
64    *
65    * @exception JMSSecurityException If the user identification is incorrect.
66    * @exception IllegalStateException If the server is not listening.
67    */
68   public javax.jms.QueueConnection JavaDoc
69       createQueueConnection(String JavaDoc name, String JavaDoc password)
70     throws javax.jms.JMSException JavaDoc {
71     return new QueueConnection(params,
72                                new TcpConnection(params,
73                                                  name,
74                                                  password,
75                                                  reliableClass));
76   }
77
78   /**
79    * Method inherited from the <code>ConnectionFactory</code> class.
80    *
81    * @exception JMSSecurityException If the user identification is incorrect.
82    * @exception IllegalStateException If the server is not listening.
83    */
84   public javax.jms.Connection JavaDoc createConnection(String JavaDoc name, String JavaDoc password)
85     throws javax.jms.JMSException JavaDoc {
86     return new Connection(params,
87                           new TcpConnection(params,
88                                             name,
89                                             password,
90                                             reliableClass));
91   }
92
93   /**
94    * Admin method creating a <code>javax.jms.QueueConnectionFactory</code>
95    * instance for creating TCP connections with a given server.
96    *
97    * @param host Name or IP address of the server's host.
98    * @param port Server's listening port.
99    */
100   public static javax.jms.QueueConnectionFactory JavaDoc
101       create(String JavaDoc host, int port) {
102     return create(host,
103                   port,
104                   "org.objectweb.joram.client.jms.tcp.ReliableTcpClient");
105   }
106
107   /**
108    * Admin method creating a <code>javax.jms.QueueConnectionFactory</code>
109    * instance for creating TCP connections with a given server.
110    *
111    * @param host Name or IP address of the server's host.
112    * @param port Server's listening port.
113    * @param reliableClass Reliable class name.
114    */
115   public static javax.jms.QueueConnectionFactory JavaDoc
116       create(String JavaDoc host,
117              int port,
118              String JavaDoc reliableClass) {
119     QueueTcpConnectionFactory cf = new QueueTcpConnectionFactory(host, port);
120     cf.setReliableClass(reliableClass);
121     return cf;
122   }
123
124   /**
125    * Admin method creating a <code>javax.jms.QueueConnectionFactory</code>
126    * instance for creating TCP connections with the local server.
127    *
128    * @exception ConnectException If the admin connection is closed or broken.
129    */
130   public static javax.jms.QueueConnectionFactory JavaDoc create()
131                 throws java.net.ConnectException JavaDoc
132   {
133     return create(AdminModule.getLocalHost(), AdminModule.getLocalPort());
134   }
135 }
136
Popular Tags