Package aQute.remote.util

Class Link<L,R>

java.lang.Object

java.lang.Thread

aQute.remote.util.Link<L,R>

Type Parameters:

R -

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class Link<L,R>
extends Thread
implements Closeable

This is a simple RPC module that has a R and L interface. The R interface is implemented on the remote side. The methods on this subclass are then available remotely. I.e. this is a two way street. Void messages are asynchronous, other messages block to a reply.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
Link(Class<R> remoteType, L local, DataInputStream in, DataOutputStream out)
Link(Class<R> remoteType, L local, InputStream in, OutputStream out)
Link(Class<R> type, L local, Socket socket)

Method Summary

Modifier and Type	Method	Description
void	close()
DataInputStream	getInput()
DataOutputStream	getOutput()
R	getRemote()
boolean	isOpen()
void	open()
void	run()
void	setRemote(Object remote)
protected void	terminate(Exception t)
void	transfer(Object result)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Details

Link

public Link(Class<R> remoteType,
 L local,
 InputStream in,
 OutputStream out)

Link

public Link(Class<R> remoteType,
 L local,
 DataInputStream in,
 DataOutputStream out)

Link

public Link(Class<R> type,
 L local,
 Socket socket)
     throws IOException

Throws:

IOException

Method Details

open

public void open()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getRemote

public R getRemote()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

terminate

protected void terminate(Exception t)

isOpen

public boolean isOpen()

getOutput

public DataOutputStream getOutput()

getInput

public DataInputStream getInput()

setRemote

public void setRemote(Object remote)

transfer

public void transfer(Object result)
              throws Exception

Throws:

Exception