public interface VirtualChannel
Channel
that allows different implementations.Modifier and Type | Method and Description |
---|---|
<V,T extends Throwable> |
call(Callable<V,T> callable)
Makes a remote procedure call.
|
<V,T extends Throwable> |
callAsync(Callable<V,T> callable)
Makes an asynchronous remote procedure call.
|
void |
close()
Performs an orderly shut down of this channel (and the remote peer.)
|
<T> T |
export(Class<T> type,
T instance)
Exports an object for remoting to the other
Channel
by creating a remotable proxy. |
void |
join()
Waits for this
Channel to be closed down. |
void |
join(long timeout)
Waits for this
Channel to be closed down, but only up the given milliseconds. |
void |
syncLocalIO()
Blocks until all the I/O packets sent from remote is fully locally executed, then return.
|
<V,T extends Throwable> V call(Callable<V,T> callable) throws IOException, T extends Throwable, InterruptedException
Sends Callable
to the remote system, executes it, and returns its result.
InterruptedException
- If the current thread is interrupted while waiting for the completion.IOException
- If there's any error in the communication between Channel
s.T extends Throwable
<V,T extends Throwable> Future<V> callAsync(Callable<V,T> callable) throws IOException
Similar to call(Callable)
but returns immediately.
The result of the Callable
can be obtained through the Future
object.
Future
object that can be used to wait for the completion.IOException
- If there's an error during the communication.void close() throws IOException
IOException
- if the orderly shut-down failed.void join() throws InterruptedException
Channel
to be closed down.
The close-down of a Channel
might be initiated locally or remotely.InterruptedException
- If the current thread is interrupted while waiting for the completion.void join(long timeout) throws InterruptedException
Channel
to be closed down, but only up the given milliseconds.InterruptedException
- If the current thread is interrupted while waiting for the completion.<T> T export(Class<T> type, T instance)
Channel
by creating a remotable proxy.
All the parameters and return values must be serializable.
type
- Interface to be remoted.Channel
, and calling methods on it from the remote side
will invoke the same method on the given local instance object.void syncLocalIO() throws InterruptedException
InterruptedException
Copyright © 2017. All rights reserved.