KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > exolab > jms > net > tcp > TCPSManagedConnectionAcceptor


1 /**
2  * Redistribution and use of this software and associated documentation
3  * ("Software"), with or without modification, are permitted provided
4  * that the following conditions are met:
5  *
6  * 1. Redistributions of source code must retain copyright
7  * statements and notices. Redistributions must also contain a
8  * copy of this document.
9  *
10  * 2. Redistributions in binary form must reproduce the
11  * above copyright notice, this list of conditions and the
12  * following disclaimer in the documentation and/or other
13  * materials provided with the distribution.
14  *
15  * 3. The name "Exolab" must not be used to endorse or promote
16  * products derived from this Software without prior written
17  * permission of Exoffice Technologies. For written permission,
18  * please contact info@exolab.org.
19  *
20  * 4. Products derived from this Software may not be called "Exolab"
21  * nor may "Exolab" appear in their names without prior written
22  * permission of Exoffice Technologies. Exolab is a registered
23  * trademark of Exoffice Technologies.
24  *
25  * 5. Due credit should be given to the Exolab Project
26  * (http://www.exolab.org/).
27  *
28  * THIS SOFTWARE IS PROVIDED BY EXOFFICE TECHNOLOGIES AND CONTRIBUTORS
29  * ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT
30  * NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
31  * FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
32  * EXOFFICE TECHNOLOGIES OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
33  * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
34  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
35  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
36  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
37  * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
38  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
39  * OF THE POSSIBILITY OF SUCH DAMAGE.
40  *
41  * Copyright 2003-2005 (C) Exoffice Technologies Inc. All Rights Reserved.
42  *
43  * $Id: TCPSManagedConnectionAcceptor.java,v 1.5 2005/05/03 13:45:59 tanderson Exp $
44  */
45 package org.exolab.jms.net.tcp;
46
47 import java.io.IOException JavaDoc;
48 import java.net.InetAddress JavaDoc;
49 import java.net.ServerSocket JavaDoc;
50 import java.net.Socket JavaDoc;
51 import javax.net.ServerSocketFactory;
52 import javax.net.ssl.SSLServerSocket;
53 import javax.net.ssl.SSLServerSocketFactory;
54
55 import EDU.oswego.cs.dl.util.concurrent.PooledExecutor;
56
57 import org.exolab.jms.net.connector.Authenticator;
58 import org.exolab.jms.net.connector.ManagedConnection;
59 import org.exolab.jms.net.connector.ResourceException;
60 import org.exolab.jms.net.connector.URIRequestInfo;
61 import org.exolab.jms.net.socket.SocketManagedConnectionAcceptor;
62 import org.exolab.jms.net.socket.SocketRequestInfo;
63 import org.exolab.jms.net.uri.URI;
64 import org.exolab.jms.net.util.SSLProperties;
65 import org.exolab.jms.net.util.SSLHelper;
66
67
68 /**
69  * Accepts SSL socket connections. constructing new
70  * <code>TCPSManagedConnection</code> instances to serve them.
71  *
72  * @author <a HREF="mailto:tma@netspace.net.au">Tim Anderson</a>
73  * @version $Revision: 1.5 $ $Date: 2005/05/03 13:45:59 $
74  */
75 class TCPSManagedConnectionAcceptor
76         extends SocketManagedConnectionAcceptor {
77
78     /**
79      * Construct a new <code>TCPSConnectionAcceptor</code>.
80      * <p/>
81      * This creates a server socket with the specified port and listen backlog.
82      * <p/>
83      * If {@link SocketRequestInfo#getBindAll()} flag can be used on multi-homed
84      * hosts to limit the addresses on which connections are accepted.
85      * If <code>false</code>, the socket will only accept connections on the
86      * address specified by {@link SocketRequestInfo#getHostAddress}.
87      * If <code>true</code> it will accept connections on all local addresses.
88      * <p/>
89      * The port returned by
90      * {@link URIRequestInfo#getPort} must be between 0 and 65535, inclusive
91      *
92      * @param authenticator the connection authenticator
93      * @param info the connection request info
94      * @throws ResourceException if a server socket cannot be created
95      */
96     public TCPSManagedConnectionAcceptor(Authenticator authenticator,
97                                          TCPSRequestInfo info)
98             throws ResourceException {
99         super(authenticator, info);
100     }
101
102
103     /**
104      * Create a new server socket.
105      *
106      * @param port the port to listen on
107      * @param backlog the listen backlog
108      * @param host if non-null, specifies to only accept connections to the
109      * specified address. If null, accept connections on any/all
110      * local addresses.
111      * @return a new server socket, listening on <code>port</code>
112      * @throws IOException if the socket can't be created
113      */
114     protected ServerSocket JavaDoc createServerSocket(int port, int backlog,
115                                               InetAddress JavaDoc host)
116             throws IOException JavaDoc {
117         TCPSRequestInfo info = (TCPSRequestInfo) getRequestInfo();
118         SSLProperties properties = info.getSSLProperties();
119         if (properties != null) {
120             SSLHelper.configure(properties);
121         }
122         ServerSocketFactory factory =
123                 SSLServerSocketFactory.getDefault();
124         SSLServerSocket socket = (SSLServerSocket) factory.createServerSocket(
125                 port, backlog, host);
126         socket.setNeedClientAuth(info.getNeedClientAuth());
127         return socket;
128     }
129
130     /**
131      * Create a new server-side <code>ManagedConnection</code> for an accepted
132      * socket connection.
133      *
134      * @param uri the URI denoting this acceptor
135      * @param socket the accepted socket connection
136      * @param authenticator the connection authenticator
137      * @param pool the thread pool for handling invocation requests
138      * @return a new server-side managed connection
139      * @throws ResourceException if the managed connection can't be created
140      */
141     protected ManagedConnection createManagedConnection(
142             URI uri, Socket JavaDoc socket, Authenticator authenticator,
143             PooledExecutor pool)
144             throws ResourceException {
145         return new TCPSManagedConnection(uri, socket, authenticator, pool);
146     }
147
148 }
149
Popular Tags