public class SocketTransportProvider extends Object implements TransportProvider
TransportProvider interface over the standard java Socket class.Socket| Modifier and Type | Field and Description |
|---|---|
static String |
BIND_ADDRESS
This constant corresponds to the
ubik.rmi.transport.socket.bind-address
system property. |
static String |
CLIENT_FACTORY
This constant corresponds to the
ubik.rmi.transport.socket.client-factory
system property (it identifies the ConnectionFactory to use to create client-side
connections). |
protected static long |
DEFAULT_RESET_INTERVAL |
static String |
MAX_THREADS
This constant corresponds to the
ubik.rmi.transport.socket.max-threads
system property. |
static String |
PORT
This constant corresponds to the
ubik.rmi.transport.socket.port
system property. |
static String |
SERVER_FACTORY
This constant corresponds to the
ubik.rmi.transport.socket.server-factory
system property. |
static String |
SOCKET_TRANSPORT_TYPE
Constant corresponding to this provider class' transport type.
|
| Modifier | Constructor and Description |
|---|---|
|
SocketTransportProvider() |
protected |
SocketTransportProvider(String transportType) |
| Modifier and Type | Method and Description |
|---|---|
protected Server |
doNewServer(int port,
Props props) |
Connections |
getPoolFor(ServerAddress address)
Returns a client connection pool to the given server address.
|
String |
getTransportType()
Returns this instance's "transport type".
|
Server |
newDefaultServer()
This method is called by Ubik RMI's runtime when a server is needed on
the client side to recieve asynchronous responses (i.e.: callbacks).
|
Server |
newServer(int port) |
Server |
newServer(Properties props)
Returns a server implementation.
|
void |
shutdown()
Shuts down this provider.
|
public static final String SOCKET_TRANSPORT_TYPE
public static final String MAX_THREADS
ubik.rmi.transport.socket.max-threads
system property.public static final String CLIENT_FACTORY
ubik.rmi.transport.socket.client-factory
system property (it identifies the ConnectionFactory to use to create client-side
connections).public static final String SERVER_FACTORY
ubik.rmi.transport.socket.server-factory
system property. It identifies the UbikServerSocketFactory implementation to use.public static final String BIND_ADDRESS
ubik.rmi.transport.socket.bind-address
system property.public static final String PORT
ubik.rmi.transport.socket.port
system property.protected static final long DEFAULT_RESET_INTERVAL
protected SocketTransportProvider(String transportType)
public SocketTransportProvider()
public Connections getPoolFor(ServerAddress address) throws RemoteException
TransportProvidergetPoolFor in interface TransportProvideraddress - a ServerAddress.ConnectionOptionsException.RemoteException - if a problem occurs creating the connection.TransportProvider.getPoolFor(ServerAddress)public Server newServer(Properties props) throws RemoteException
TransportProvidernewServer in interface TransportProviderprops - the Properties used to create the server.Server instance.RemoteExceptionTransportProvider.newServer(Properties)public Server newDefaultServer() throws RemoteException
TransportProviderServer instance.newDefaultServer in interface TransportProviderServer.RemoteExceptionTransportProvider.newDefaultServer()public Server newServer(int port) throws RemoteException
RemoteExceptionprotected Server doNewServer(int port, Props props) throws RemoteException
RemoteExceptionpublic String getTransportType()
TransportProvidergetTransportType in interface TransportProviderTransportProvider.getTransportType()public void shutdown()
TransportProvidershutdown in interface TransportProviderTransportProvider.shutdown()Copyright © 2012 Sapia OSS. All Rights Reserved.