org.ow2.proactive.authentication

Class Connection<T extends Authentication>

java.lang.Object

org.ow2.proactive.authentication.Connection<T>

Type Parameters:

T - the real type of authentication

All Implemented Interfaces:

Serializable, Loggable

Direct Known Subclasses:

RMConnection, SchedulerConnection

public abstract class Connection<T extends Authentication>
extends Object
implements Loggable, Serializable

Class implements connection to the service with authentication. It attempts lookup authentication active object and checks that system is up and running (in another words authentication object is activated). Provides an ability to connect in blocking and non blocking manner.

Since:

ProActive Scheduling 0.9.1

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Connection(Class<? extends Authentication> clazz) Create a new instance of Connection

Method Summary

Modifier and Type	Method and Description
T	connect(String url) Connect to the service with given url.
static String	getNetworkInterfaceFor(String url) Selects a network interface for proactive runtime based on provided url.
static URI	normalize(String url) Normalize the URL url.
T	waitAndConnect(String url) Connects to the service using given URL.
T	waitAndConnect(String url, long timeout) Connects to the service with a specified timeout value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.ow2.proactive.authentication.Loggable

getLogger

Constructor Detail

Connection

public Connection(Class<? extends Authentication> clazz)

Create a new instance of Connection

Parameters:

clazz - the real type of the authentication

Method Detail

connect

public T connect(String url)
          throws Exception

Connect to the service with given url. If it is not available or initializing throws an exception.

Parameters:

url - the URL of the service to join.

Returns:

the service authentication interface at the specified URL.

Throws:

Exception - if something wrong append

waitAndConnect

public T waitAndConnect(String url)
                 throws Exception

Connects to the service using given URL. The current thread will be block until connection established or an error occurs.

Parameters:

url - the url on which to connect

Returns:

the authentication if connection succeed

Throws:

Exception - if something wrong append

waitAndConnect

public T waitAndConnect(String url,
                        long timeout)
                 throws Exception

Connects to the service with a specified timeout value. A timeout of zero is interpreted as an infinite timeout. The connection will then block until established or an error occurs.

Parameters:

url - the url on which to connect

timeout - the maximum amount of time to wait if it cannot connect

Returns:

the authentication if connection succeed

Throws:

Exception - if something wrong append

normalize

public static URI normalize(String url)

Normalize the URL url.

Parameters:

url, - the URL to normalize.

Returns:

the default base URI if the given url is null. @see RemoteObjectFactory
the given URL with // prepended if it does not contain any scheme identifier the given URL with / appended if URL does not end with / and does not contain any path element,
or the given URL, unchanged.

getNetworkInterfaceFor

public static String getNetworkInterfaceFor(String url)
                                     throws IOException,
                                            URISyntaxException

Selects a network interface for proactive runtime based on provided url.

Throws:

IOException - if an I/O error occurs when creating the socket.

UnknownHostException - if the IP address of the host could not be determined.

URISyntaxException - if the given string violates RFC 2396,