edu.iu.dsc.tws.master.worker

Class JMDriverAgent

java.lang.Object

edu.iu.dsc.tws.master.worker.JMDriverAgent

All Implemented Interfaces:

MessageHandler, ISenderToDriver

public class JMDriverAgent
extends java.lang.Object
implements ISenderToDriver, MessageHandler

Constructor Summary

Constructors

Constructor and Description
JMDriverAgent(RRClient rrClient, int workerID)

Method Summary

Modifier and Type	Method and Description
boolean	addReceiverFromDriver(IReceiverFromDriver receiverFromDriver1) only one IReceiverFromDriver can be added if the second IReceiverFromDriver tried to be added, returns false
void	onMessage(RequestID id, int workerId, Message message) Handles a specific message type
boolean	sendToDriver(Message message) send a protocol buffer message to the driver in the job

Methods inherited from class java.lang.Object

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

Constructor Detail

JMDriverAgent

public JMDriverAgent(RRClient rrClient,
                     int workerID)

Method Detail

addReceiverFromDriver

public boolean addReceiverFromDriver(IReceiverFromDriver receiverFromDriver1)

only one IReceiverFromDriver can be added if the second IReceiverFromDriver tried to be added, returns false

sendToDriver

public boolean sendToDriver(Message message)

Description copied from interface: ISenderToDriver

send a protocol buffer message to the driver in the job

Specified by:

sendToDriver in interface ISenderToDriver

Returns:

onMessage

public void onMessage(RequestID id,
                      int workerId,
                      Message message)

Description copied from interface: MessageHandler

Handles a specific message type

Specified by:

onMessage in interface MessageHandler

Parameters:

id - request id

workerId - worker id

message - protbuf message