aQute.remote.util

Class AgentSupervisor<Supervisor,Agent>

java.lang.Object

aQute.remote.util.AgentSupervisor<Supervisor,Agent>

Type Parameters:

Supervisor - The supervisor type

Agent - The agent type

public class AgentSupervisor<Supervisor,Agent>
extends java.lang.Object

This is a base class that provides the basic functionality of a supervisor. In general an actual supervisor extends this class to provide the functionality to use on the client side.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	exitCode

Constructor Summary

Constructors

Constructor and Description
AgentSupervisor()

Method Summary

Modifier and Type	Method and Description
java.lang.String	addFile(java.io.File file)
void	close()
protected void	connect(java.lang.Class<Agent> agent, Supervisor supervisor, java.lang.String host, int port)
protected void	connect(java.lang.Class<Agent> agent, Supervisor supervisor, java.lang.String host, int port, int timeout)
protected void	exit(int exitCode)
Agent	getAgent()
byte[]	getFile(java.lang.String sha)
boolean	isOpen()
int	join()
void	setAgent(Link<Supervisor,Agent> link)

Methods inherited from class java.lang.Object

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

Field Detail

exitCode

protected volatile int exitCode

Constructor Detail

AgentSupervisor

public AgentSupervisor()

Method Detail

connect

protected void connect(java.lang.Class<Agent> agent,
                       Supervisor supervisor,
                       java.lang.String host,
                       int port)
                throws java.lang.Exception

Throws:

java.lang.Exception

connect

protected void connect(java.lang.Class<Agent> agent,
                       Supervisor supervisor,
                       java.lang.String host,
                       int port,
                       int timeout)
                throws java.lang.Exception

Throws:

java.lang.Exception

getFile

public byte[] getFile(java.lang.String sha)
               throws java.lang.Exception

Throws:

java.lang.Exception

setAgent

public void setAgent(Link<Supervisor,Agent> link)

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

join

public int join()
         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

exit

protected void exit(int exitCode)

getAgent

public Agent getAgent()

addFile

public java.lang.String addFile(java.io.File file)
                         throws java.security.NoSuchAlgorithmException,
                                java.lang.Exception

Throws:

java.security.NoSuchAlgorithmException

java.lang.Exception

isOpen

public boolean isOpen()