aQute.remote.plugin

Class LauncherSupervisor

java.lang.Object

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

aQute.remote.plugin.LauncherSupervisor

All Implemented Interfaces:

Supervisor

public class LauncherSupervisor
extends AgentSupervisor<Supervisor,Agent>
implements Supervisor

This is the supervisor on the bnd launcher side. It provides the SHA repository for the agent and handles the redirection. It also handles the events.

Field Summary

Fields inherited from class aQute.remote.util.AgentSupervisor

exitCode

Constructor Summary

Constructors

Constructor and Description
LauncherSupervisor()

Method Summary

Modifier and Type	Method and Description
void	abort()
void	connect(java.lang.String host, int port)
void	event(Event e) An event sent from the agent.
int	getExitCode()
void	redirect(int shell)
void	setShell(int shellPort) The shell port to use.
void	setStderr(java.lang.Appendable err)
void	setStdin(java.io.InputStream in)
void	setStdout(java.lang.Appendable out)
void	setStreams(java.lang.Appendable out, java.lang.Appendable err)
boolean	stderr(java.lang.String out) Redirected standard error.
boolean	stdout(java.lang.String out) Redirected standard output

Methods inherited from class aQute.remote.util.AgentSupervisor

addFile, close, connect, connect, exit, getAgent, getFile, isOpen, join, setAgent

Methods inherited from class java.lang.Object

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

Methods inherited from interface aQute.remote.api.Supervisor

getFile

Constructor Detail

LauncherSupervisor

public LauncherSupervisor()

Method Detail

event

public void event(Event e)
           throws java.lang.Exception

Description copied from interface: Supervisor

An event sent from the agent.

Specified by:

event in interface Supervisor

Parameters:

e - the event

Throws:

java.lang.Exception

stdout

public boolean stdout(java.lang.String out)
               throws java.lang.Exception

Description copied from interface: Supervisor

Redirected standard output

Specified by:

stdout in interface Supervisor

Parameters:

out - the text that was redirected

Returns:

ignored (to make sync)

Throws:

java.lang.Exception

stderr

public boolean stderr(java.lang.String out)
               throws java.lang.Exception

Description copied from interface: Supervisor

Redirected standard error.

Specified by:

stderr in interface Supervisor

Parameters:

out - the text that was redirected

Returns:

ignored (to make sync)

Throws:

java.lang.Exception

setStdout

public void setStdout(java.lang.Appendable out)
               throws java.lang.Exception

Throws:

java.lang.Exception

setStderr

public void setStderr(java.lang.Appendable err)
               throws java.lang.Exception

Throws:

java.lang.Exception

setStdin

public void setStdin(java.io.InputStream in)
              throws java.lang.Exception

Throws:

java.lang.Exception

setStreams

public void setStreams(java.lang.Appendable out,
                       java.lang.Appendable err)
                throws java.lang.Exception

Throws:

java.lang.Exception

connect

public void connect(java.lang.String host,
                    int port)
             throws java.lang.Exception

Throws:

java.lang.Exception

setShell

public void setShell(int shellPort)

The shell port to use.

• <0 – Attach to a local Gogo CommandSession
• 0 – Use the standard console
• else – Open a stream to that port

Parameters:

shellPort -

getExitCode

public int getExitCode()

abort

public void abort()
           throws java.lang.Exception

Throws:

java.lang.Exception

redirect

public void redirect(int shell)
              throws java.lang.Exception

Throws:

java.lang.Exception