|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.remoting.AbstractInvoker
org.jboss.remoting.MicroRemoteClientInvoker
org.jboss.remoting.RemoteClientInvoker
org.jboss.remoting.transport.rmi.RMIClientInvoker
public class RMIClientInvoker
RMIClientInvoker
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.jboss.remoting.AbstractInvoker |
---|
AbstractInvoker.CallbackLocatorHolder |
Field Summary | |
---|---|
static java.lang.String |
MAX_NUM_TIMEOUT_THREADS
Key for the configuration map that determines the threadpool size for simulated timeouts. |
static int |
MAX_NUM_TIMEOUT_THREADS_DEFAULT
Specifies the default number of work threads in the thread pool for simulating timeouts. |
static java.lang.String |
MAX_TIMEOUT_QUEUE_SIZE
Key for the configuration map that determines the queue size for simulated timeout threadpool. |
protected boolean |
rmiOnewayMarshalling
|
Fields inherited from class org.jboss.remoting.MicroRemoteClientInvoker |
---|
connectHomes, parentFirstClassLoading |
Fields inherited from class org.jboss.remoting.AbstractInvoker |
---|
classbyteloader, configuration, localServerLocators, locator, serializationType, socketFactory, socketFactoryCreatedFromSSLParameters, version |
Constructor Summary | |
---|---|
RMIClientInvoker(InvokerLocator locator)
|
|
RMIClientInvoker(InvokerLocator locator,
java.util.Map configuration)
|
Method Summary | |
---|---|
protected void |
configureParameters()
|
protected java.lang.String |
getDefaultDataType()
Each implementation of the remote client invoker should have a default data type that is uses in the case it is not specified in the invoker locator uri. |
RMIServerInvokerInf |
getServerStub()
return the RMI server stub |
org.jboss.util.threadpool.ThreadPool |
getTimeoutThreadPool()
Gets the thread pool being used for simulating timeouts. |
protected Home |
getUsableAddress()
|
protected void |
handleConnect()
subclasses must implement this method to provide a hook to connect to the remote server, if this applies to the specific transport. |
protected void |
handleDisconnect()
subclasses must implement this method to provide a hook to disconnect from the remote server, if this applies to the specific transport. |
void |
setServerStub(RMIServerInvokerInf server)
get the server stub |
protected void |
storeLocalConfig(java.util.Map config)
|
protected java.lang.Object |
transport(java.lang.String sessionId,
java.lang.Object invocation,
java.util.Map metadata,
Marshaller marshaller,
UnMarshaller unmarshaller)
|
protected java.lang.Object |
unmarshal(java.lang.Object o,
UnMarshaller unmarshaller,
java.util.Map metadata)
|
Methods inherited from class org.jboss.remoting.MicroRemoteClientInvoker |
---|
connect, disconnect, establishLease, finalize, getConnectHomes, getLeasePeriod, getMarshaller, getSessionId, getUnMarshaller, init, invoke, isConnected, postProcess, preProcess, setMarshaller, setUnMarshaller, terminateLease |
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.jboss.remoting.transport.ClientInvoker |
---|
addClientLocator, getClientLocator, getClientLocators, getSocketFactory, setSocketFactory |
Methods inherited from interface org.jboss.remoting.Invoker |
---|
getLocator |
Field Detail |
---|
public static final java.lang.String MAX_NUM_TIMEOUT_THREADS
public static final java.lang.String MAX_TIMEOUT_QUEUE_SIZE
public static final int MAX_NUM_TIMEOUT_THREADS_DEFAULT
protected boolean rmiOnewayMarshalling
Constructor Detail |
---|
public RMIClientInvoker(InvokerLocator locator)
public RMIClientInvoker(InvokerLocator locator, java.util.Map configuration)
Method Detail |
---|
protected void configureParameters()
public void setServerStub(RMIServerInvokerInf server)
server
- public RMIServerInvokerInf getServerStub()
protected void handleConnect() throws ConnectionFailedException
handleConnect
in class MicroRemoteClientInvoker
ConnectionFailedException
protected Home getUsableAddress()
protected void handleDisconnect()
handleDisconnect
in class MicroRemoteClientInvoker
protected java.lang.String getDefaultDataType()
MicroRemoteClientInvoker
getDefaultDataType
in class MicroRemoteClientInvoker
protected void storeLocalConfig(java.util.Map config)
protected java.lang.Object transport(java.lang.String sessionId, java.lang.Object invocation, java.util.Map metadata, Marshaller marshaller, UnMarshaller unmarshaller) throws java.io.IOException, ConnectionFailedException
transport
in class MicroRemoteClientInvoker
java.io.IOException
ConnectionFailedException
protected java.lang.Object unmarshal(java.lang.Object o, UnMarshaller unmarshaller, java.util.Map metadata) throws java.io.IOException
java.io.IOException
public org.jboss.util.threadpool.ThreadPool getTimeoutThreadPool()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |