edu.iu.dsc.tws.master.driver

Class DriverMessenger

java.lang.Object

edu.iu.dsc.tws.master.driver.DriverMessenger

All Implemented Interfaces:

IDriverMessenger

public class DriverMessenger
extends java.lang.Object
implements IDriverMessenger

Constructor Summary

Constructors

Constructor and Description
DriverMessenger(WorkerMonitor workerMonitor)

Method Summary

Modifier and Type	Method and Description
boolean	broadcastToAllWorkers(Message message) send this message to all workers in the job
boolean	sendToWorker(Message message, java.lang.Integer workerID) send a protocol buffer message to a worker in the job
boolean	sendToWorkerList(Message message, java.util.List<java.lang.Integer> workerList) send a protocol buffer message to a list of workers in the job

Methods inherited from class java.lang.Object

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

Constructor Detail

DriverMessenger

public DriverMessenger(WorkerMonitor workerMonitor)

Method Detail

broadcastToAllWorkers

public boolean broadcastToAllWorkers(Message message)

send this message to all workers in the job

Specified by:

broadcastToAllWorkers in interface IDriverMessenger

Returns:

sendToWorkerList

public boolean sendToWorkerList(Message message,
                                java.util.List<java.lang.Integer> workerList)

Description copied from interface: IDriverMessenger

send a protocol buffer message to a list of workers in the job

Specified by:

sendToWorkerList in interface IDriverMessenger

Returns:

sendToWorker

public boolean sendToWorker(Message message,
                            java.lang.Integer workerID)

Description copied from interface: IDriverMessenger

send a protocol buffer message to a worker in the job

Specified by:

sendToWorker in interface IDriverMessenger

Returns: