Package ej.rcommand.synchronous

Class RemoteCommandClient

java.lang.Object

ej.rcommand.synchronous.RemoteCommandClient

All Implemented Interfaces:

Runnable

public class RemoteCommandClient
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor	Description
RemoteCommandClient(StreamRemoteConnection connection)

Method Summary

Modifier and Type	Method	Description
<T> T	execute(Command<T> command, long timeout)	Executes the command and waits for the result.
void	registerNotificationListener(RemoteNotificationListener listener)	Registers the given notification listener.
void	run()	When an object implementing interface Runnable is used to create a thread, starting the thread causes the object's run method to be called in that separately executing thread.
void	stop()	Stops the client.

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteCommandClient

public RemoteCommandClient(StreamRemoteConnection connection)

Method Detail

registerNotificationListener

public void registerNotificationListener(RemoteNotificationListener listener)

Registers the given notification listener.

Parameters:

listener - the notification listener to register.

run

public void run()

Description copied from interface: Runnable

When an object implementing interface Runnable is used to create a thread, starting the thread causes the object's run method to be called in that separately executing thread.

The general contract of the method run is that it may take any action whatsoever.

Specified by:

run in interface Runnable

See Also:

Thread.run()

execute

public <T> T execute(Command<T> command,
                     long timeout)
              throws IOException,
                     InterruptedException,
                     TimeoutException

Executes the command and waits for the result.

Parameters:

command - the command to execute.

timeout - the timeout in milliseconds.

Returns:

the result of the command.

Throws:

IOException - if an I/O error occurs.

InterruptedException

TimeoutException - if the response of the command is not received before timeout.

stop

public void stop()

Stops the client.