org.apache.reef.runtime.common.driver.client

Class JobMessageObserverImpl

java.lang.Object

org.apache.reef.runtime.common.driver.client.JobMessageObserverImpl

All Implemented Interfaces:

JobMessageObserver

public final class JobMessageObserverImpl
extends Object
implements JobMessageObserver

An implementation of JobMessageObserver.

Constructor Summary

Constructors

Constructor and Description
JobMessageObserverImpl(ClientConnection clientConnection)

Method Summary

Modifier and Type	Method and Description
void	sendMessageToClient(byte[] message) Send a message to the client.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobMessageObserverImpl

@Inject
public JobMessageObserverImpl(ClientConnection clientConnection)

Method Detail

sendMessageToClient

public void sendMessageToClient(byte[] message)

Description copied from interface: JobMessageObserver

Send a message to the client.

Specified by:

sendMessageToClient in interface JobMessageObserver

Parameters:

message - a message to be sent to the client