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:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable

public class Link<L,R>
extends java.lang.Thread
implements java.io.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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Link(java.lang.Class<R> remoteType, L local, java.io.DataInputStream in, java.io.DataOutputStream out)
Link(java.lang.Class<R> remoteType, L local, java.io.InputStream in, java.io.OutputStream out)
Link(java.lang.Class<R> type, L local, java.net.Socket socket)

Method Summary

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

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Link

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

Link

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

Link

public Link(java.lang.Class<R> type,
            L local,
            java.net.Socket socket)
     throws java.io.IOException

Throws:

java.io.IOException

Method Detail

open

public void open()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

getRemote

public R getRemote()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

terminate

protected void terminate(java.lang.Exception t)

isOpen

public boolean isOpen()

getOutput

public java.io.DataOutputStream getOutput()

getInput

public java.io.DataInputStream getInput()

setRemote

public void setRemote(java.lang.Object remote)

transfer

public void transfer(java.lang.Object result)
              throws java.lang.Exception

Throws:

java.lang.Exception