net.sourceforge.esw.transport
Class RMITransportDelegate

java.lang.Object
  |
  +--net.sourceforge.esw.transport.RMITransportDelegate

All Implemented Interfaces:

ITransportDelegate

public class RMITransportDelegate

extends java.lang.Object

implements ITransportDelegate

This is the entry point to the Transport system. Clients wishing to use transport must first startup the Transport system using methods in this object.

Distrubuted Garbage Collection Lease time can be modified by a SystemProperty of the form: Property prop = System.getProperties(); prop.put("java.rmi.dgc.leaseValue", 120000); also sun.rmi.dgc.client.gcInterval and sun.rmi.dgc.server.gcInterval This implementation is responsible for RMI transport.

Field Summary

static int	DEFAULT_CONNECTION_IDLE_TIMEOUT DEFAULT_CONNECTION_IDLE_TIMEOUT
static int	DEFAULT_CONNECTION_TIMEOUT DEFAULT_CONNECTION_TIMEOUT
static int	DEFAULT_MAX_CLIENT_CONNECTIONS DEFAULT_MAX_CLIENT_CONNECTIONS
static int	DEFAULT_MAX_CONNECTIONS DEFAULT_MAX_CONNECTIONS
static int	DEFAULT_MAX_SERVER_CONNECTIONS DEFAULT_MAX_SERVER_CONNECTIONS
static int	DEFAULT_RETRY_LIMIT DEFAULT_RETRY_LIMIT
static java.lang.String	RMI_CONNECTION_IDLE_TIMEOUT_PROPERTY RMIConnectionIdleTimeoutProperty
static java.lang.String	RMI_CONNECTION_RETRY_LIMIT_PROPERTY RMIConnectionRetryLimitProperty
static java.lang.String	RMI_CONNECTION_TIMEOUT_PROPERTY RMIConnectionTimeoutProperty
static java.lang.String	RMI_MAX_CLIENT_CONNECTIONS_PROPERTY RMIMaxClientConnectionsProperty
static java.lang.String	RMI_MAX_CONNECTIONS_PROPERTY RMIMaxConnectionsProperty
static java.lang.String	RMI_MAX_SERVER_CONNECTIONS_PROPERTY RMIMaxServerConnectionsProperty
static java.lang.String	RMI_USE_LOCAL_REGISTRY_PROPERTY Constant string for the optional property of using a local RMI registry on this machine instead of creating one.

Constructor Summary

RMITransportDelegate()

Method Summary

protected java.util.ArrayList	getClientConnectionList()
java.lang.Object	getProxy(java.lang.Object aObject) Creates a Proxy object that can be sent to remote clients that allows remote method calls to be made against the specified object.
protected java.util.ArrayList	getServerConnectionList()
boolean	isBelowMaxConnections()
protected void	setupProperties()
void	startup() Starts up the Transport system.
void	startup(int aPort) Starts up the Transport system at the specified port.

Methods inherited from class java.lang.Object

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

Field Detail

RMI_USE_LOCAL_REGISTRY_PROPERTY

public static final java.lang.String RMI_USE_LOCAL_REGISTRY_PROPERTY

Constant string for the optional property of using a local RMI registry on this machine instead of creating one. If this property is set to true the LocateRegistry.createRegistry( aPort ) will not be called, otherwise, it will be called to initialize the in-VM RMI Registry. Simply add this property, with the name of "RMIUseLocalRegistryProperty" to the System properties or ESW properties to true to avoid this step.

RMI_CONNECTION_TIMEOUT_PROPERTY

public static final java.lang.String RMI_CONNECTION_TIMEOUT_PROPERTY

RMIConnectionTimeoutProperty

RMI_MAX_CONNECTIONS_PROPERTY

public static final java.lang.String RMI_MAX_CONNECTIONS_PROPERTY

RMIMaxConnectionsProperty

RMI_CONNECTION_IDLE_TIMEOUT_PROPERTY

public static final java.lang.String RMI_CONNECTION_IDLE_TIMEOUT_PROPERTY

RMIConnectionIdleTimeoutProperty

RMI_MAX_SERVER_CONNECTIONS_PROPERTY

public static final java.lang.String RMI_MAX_SERVER_CONNECTIONS_PROPERTY

RMIMaxServerConnectionsProperty

RMI_MAX_CLIENT_CONNECTIONS_PROPERTY

public static final java.lang.String RMI_MAX_CLIENT_CONNECTIONS_PROPERTY

RMIMaxClientConnectionsProperty

RMI_CONNECTION_RETRY_LIMIT_PROPERTY

public static final java.lang.String RMI_CONNECTION_RETRY_LIMIT_PROPERTY

RMIConnectionRetryLimitProperty

DEFAULT_RETRY_LIMIT

public static final int DEFAULT_RETRY_LIMIT

DEFAULT_RETRY_LIMIT

DEFAULT_CONNECTION_IDLE_TIMEOUT

public static final int DEFAULT_CONNECTION_IDLE_TIMEOUT

DEFAULT_CONNECTION_IDLE_TIMEOUT

DEFAULT_CONNECTION_TIMEOUT

public static final int DEFAULT_CONNECTION_TIMEOUT

DEFAULT_CONNECTION_TIMEOUT

DEFAULT_MAX_CONNECTIONS

public static final int DEFAULT_MAX_CONNECTIONS

DEFAULT_MAX_CONNECTIONS

DEFAULT_MAX_CLIENT_CONNECTIONS

public static final int DEFAULT_MAX_CLIENT_CONNECTIONS

DEFAULT_MAX_CLIENT_CONNECTIONS

DEFAULT_MAX_SERVER_CONNECTIONS

public static final int DEFAULT_MAX_SERVER_CONNECTIONS

DEFAULT_MAX_SERVER_CONNECTIONS

Constructor Detail

RMITransportDelegate

public RMITransportDelegate()

Method Detail

startup

public void startup()
             throws java.lang.Exception

Starts up the Transport system.

Specified by:

startup in interface ITransportDelegate

startup

public void startup(int aPort)
             throws java.lang.Exception

Starts up the Transport system at the specified port.

Specified by:

startup in interface ITransportDelegate

Parameters:

aPort - the port on which to start the trasport.

getProxy

public java.lang.Object getProxy(java.lang.Object aObject)
                          throws java.lang.Exception

Creates a Proxy object that can be sent to remote clients that allows remote method calls to be made against the specified object.

Specified by:

getProxy in interface ITransportDelegate

Parameters:

aObject - the Object to create a Proxy from

Throws:

java.lang.Exception - if an error occured during creation of the Proxy.

isBelowMaxConnections

public boolean isBelowMaxConnections()

getServerConnectionList

protected java.util.ArrayList getServerConnectionList()

getClientConnectionList

protected java.util.ArrayList getClientConnectionList()

setupProperties

protected void setupProperties()