org.apache.reef.examples.suspend

Class SuspendClientControl

java.lang.Object

org.apache.reef.examples.suspend.SuspendClientControl

All Implemented Interfaces:

AutoCloseable

public class SuspendClientControl
extends Object
implements AutoCloseable

(Wake) listener to get suspend/resume commands from Control process.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SuspendClientControl.Port Port for suspend/resume control commands.

Constructor Summary

Constructors

Constructor and Description
SuspendClientControl(int port, TransportFactory tpFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	setRunningJob(RunningJob job)

Methods inherited from class java.lang.Object

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

Constructor Detail

SuspendClientControl

@Inject
public SuspendClientControl(int port,
                           TransportFactory tpFactory)
                     throws IOException

Throws:

IOException

Method Detail

setRunningJob

public void setRunningJob(RunningJob job)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception