|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.remoting.AbstractInvoker org.jboss.remoting.MicroRemoteClientInvoker
public abstract class MicroRemoteClientInvoker
MicroRemoteClientInvoker is an abstract client part handler that implements the bulk of the heavy lifting to process a remote method and dispatch it to a remote ServerInvoker and handle the result.
Specialized Client/Server Invokers might add additional functionality as part of the invocation - such as delivering queued notifcations from a remote server by adding the notification objects during each invocation to the invocation result payload and then having the client re-dispatch the notifications locally upon receiving the return invocation result. The reason for the name micro is that this class contains only api that can be run within a J2ME envrionment.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.jboss.remoting.AbstractInvoker |
---|
AbstractInvoker.CallbackLocatorHolder |
Field Summary | |
---|---|
protected boolean |
connected
|
Fields inherited from class org.jboss.remoting.AbstractInvoker |
---|
classbyteloader, configuration, localServerLocators, locator, passConfigMapToMarshalFactory, serializationType, socketFactory, socketFactoryCreatedFromSSLParameters |
Constructor Summary | |
---|---|
MicroRemoteClientInvoker(InvokerLocator locator)
|
|
MicroRemoteClientInvoker(InvokerLocator locator,
java.util.Map configuration)
|
Method Summary | |
---|---|
void |
connect()
Connect to the remote invoker. |
void |
disconnect()
disconnect from the remote invokere |
void |
establishLease(java.lang.String clientSessionID,
java.util.Map configuration,
long leasePeriod)
|
protected void |
finalize()
Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. |
protected abstract 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. |
long |
getLeasePeriod(java.lang.String sessionID)
|
protected LeasePinger |
getLeasePinger()
|
Marshaller |
getMarshaller()
|
java.lang.String |
getSessionId()
|
UnMarshaller |
getUnMarshaller()
|
protected abstract 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 abstract void |
handleDisconnect()
Subclasses must implement this method to provide a hook to disconnect from the remote server, if this applies to the specific transport. |
protected void |
init()
|
java.lang.Object |
invoke(InvocationRequest invocationReq)
Transport a request against a remote ServerInvoker. |
boolean |
isConnected()
Subclasses must provide this method to return true if their remote connection is connected and false if disconnected. |
protected void |
postProcess(java.lang.String sessionId,
java.lang.Object param,
java.util.Map sendPayload,
java.util.Map receivedPayload)
this method is called prior to returning the result for the invocation to allow the subclass the ability to modify the result result |
protected void |
preProcess(java.lang.String sessionId,
java.lang.Object param,
java.util.Map sendPayload,
java.util.Map receivedPayload)
this method is called prior to making the remote invocation to allow the subclass the ability to provide additional data or modify the invocation |
void |
setMarshaller(Marshaller marshaller)
|
void |
setUnMarshaller(UnMarshaller unmarshaller)
|
void |
terminateLease(java.lang.String sessionId,
int disconnectTimeout)
Must behave as a noop if there's no active lease. |
void |
terminateLease(java.lang.String sessionId,
int disconnectTimeout,
LeasePinger passedLeasePinger)
|
protected abstract java.lang.Object |
transport(java.lang.String sessionId,
java.lang.Object invocation,
java.util.Map metadata,
Marshaller marshaller,
UnMarshaller unmarshaller)
|
Methods inherited from class org.jboss.remoting.AbstractInvoker |
---|
addClientLocator, createSocketFactory, getClassLoader, getClientLocator, getClientLocators, getConfiguration, getLocator, getSerializationType, getSocketFactory, isCompleteSocketFactory, isSocketFactoryCreatedFromSSLParameters, needsCustomSSLConfiguration, setClassLoader, setSerializationType, setSocketFactory, wrapSocketFactory |
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 |
---|
protected boolean connected
Constructor Detail |
---|
public MicroRemoteClientInvoker(InvokerLocator locator)
public MicroRemoteClientInvoker(InvokerLocator locator, java.util.Map configuration)
Method Detail |
---|
public java.lang.Object invoke(InvocationRequest invocationReq) throws java.lang.Throwable
invoke
in interface ClientInvoker
java.lang.Throwable
protected void preProcess(java.lang.String sessionId, java.lang.Object param, java.util.Map sendPayload, java.util.Map receivedPayload)
sessionId
- param
- sendPayload
- receivedPayload
- protected void postProcess(java.lang.String sessionId, java.lang.Object param, java.util.Map sendPayload, java.util.Map receivedPayload)
sessionId
- param
- sendPayload
- receivedPayload
- protected abstract 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, java.lang.ClassNotFoundException
java.io.IOException
ConnectionFailedException
java.lang.ClassNotFoundException
public boolean isConnected()
isConnected
in interface ClientInvoker
public void connect() throws ConnectionFailedException
connect
in interface ClientInvoker
ConnectionFailedException
protected abstract void handleConnect() throws ConnectionFailedException
ConnectionFailedException
protected abstract void handleDisconnect()
public void disconnect()
disconnect
in interface ClientInvoker
public void setMarshaller(Marshaller marshaller)
setMarshaller
in interface ClientInvoker
public Marshaller getMarshaller()
getMarshaller
in interface ClientInvoker
public void setUnMarshaller(UnMarshaller unmarshaller)
setUnMarshaller
in interface ClientInvoker
public UnMarshaller getUnMarshaller()
getUnMarshaller
in interface ClientInvoker
public java.lang.String getSessionId()
public void terminateLease(java.lang.String sessionId, int disconnectTimeout)
ClientInvoker
terminateLease
in interface ClientInvoker
public void terminateLease(java.lang.String sessionId, int disconnectTimeout, LeasePinger passedLeasePinger)
public long getLeasePeriod(java.lang.String sessionID)
getLeasePeriod
in interface ClientInvoker
public void establishLease(java.lang.String clientSessionID, java.util.Map configuration, long leasePeriod) throws java.lang.Throwable
establishLease
in interface ClientInvoker
java.lang.Throwable
protected void init()
protected abstract java.lang.String getDefaultDataType()
protected void finalize() throws java.lang.Throwable
finalize
method to dispose of
system resources or to perform other cleanup.
The general contract of finalize is that it is invoked
if and when the JavaTM virtual
machine has determined that there is no longer any
means by which this object can be accessed by any thread that has
not yet died, except as a result of an action taken by the
finalization of some other object or class which is ready to be
finalized. The finalize method may take any action, including
making this object available again to other threads; the usual purpose
of finalize, however, is to perform cleanup actions before
the object is irrevocably discarded. For example, the finalize method
for an object that represents an input/output connection might perform
explicit I/O transactions to break the connection before the object is
permanently discarded.
The finalize method of class Object performs no
special action; it simply returns normally. Subclasses of
Object may override this definition.
The Java programming language does not guarantee which thread will
transport the finalize method for any given object. It is
guaranteed, however, that the thread that invokes finalize will not
be holding any user-visible synchronization locks when finalize is
invoked. If an uncaught exception is thrown by the finalize method,
the exception is ignored and finalization of that object terminates.
After the finalize method has been invoked for an object, no
further action is taken until the Java virtual machine has again
determined that there is no longer any means by which this object can
be accessed by any thread that has not yet died, including possible
actions by other objects or classes which are ready to be finalized,
at which point the object may be discarded.
The finalize method is never invoked more than once by a Java
virtual machine for any given object.
Any exception thrown by the finalize
method causes
the finalization of this object to be halted, but is otherwise
ignored.
finalize
in class java.lang.Object
java.lang.Throwable
- the Exception
raised by this methodprotected LeasePinger getLeasePinger()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |