cgl.imr.message
Class PubSubMessage

java.lang.Object
  extended by cgl.imr.message.PubSubMessage
All Implemented Interfaces:
TwisterConstants, TwisterSerializable
Direct Known Subclasses:
CombineInput, DirListRequest, DirListResponse, EndJobRequest, MapperRequest, MapTaskRequest, NewJobRequest, ReduceInput, ReducerRequest, TaskStatus, WorkerResponse

public abstract class PubSubMessage
extends Object
implements TwisterSerializable, TwisterConstants

Abstract class capturing the common characteristics of pub-sub messages.


Nested Class Summary
 
Nested classes/interfaces inherited from interface cgl.imr.base.TwisterConstants
TwisterConstants.JobState
 
Field Summary
protected  boolean hasRefMsgId
           
protected  String refMsgId
           
 
Fields inherited from interface cgl.imr.base.TwisterConstants
COMBINE_INPUT, COMBINE_TOPIC_BASE, DIR_LIST_REQ, DIR_LIST_RES, FAILED, FIXED_DATA_FILE, FIXED_DATA_MODEL, HEP_DATA_STRING, MAP_ITERATIONS_OVER, MAP_REDUCE_TOPIC_BASE, MAP_TASK, MAP_TASK_REQUEST, MAP_WORKER_STARTED, MAPPER_REQUEST, MONITOR_REQUEST, MONITOR_RESPONSE, MONITOR_SLEEP_TIME, NEW_JOB_REQUEST, NEW_JOB_RESPONSE, NUM_MAP_TASKS, NUM_REDUCE_TASKS, PARTITION_FILE_RESPONSE_TOPIC_BASE, PARTITION_FILE_SPLIT_PATTERN, PROPERTIES_FILE, REDUCE_INPUT, REDUCE_RESPONSE, REDUCE_TASK, REDUCE_TASK_REQUEST, REDUCE_TOPIC_BASE, REDUCE_WORKER_REQUEST, RESPONSE_TOPIC_BASE, SEND_RECV_MAX_SLEEP_TIME, SEND_RECV_SLEEP_TIME, SUCCESS, TASK_STATUS, WORKER_RESPONSE
 
Constructor Summary
PubSubMessage()
           
 
Method Summary
abstract  void fromBytes(byte[] bytes)
          Construct the object back from a previously serialized bytes.
abstract  byte[] getBytes()
          Serialize the object and returns the bytes.
 String getRefMessageId()
           
 void readRefIdIfAny(DataInputStream din)
           
 void serializeRefId(DataOutputStream dout)
           
 void setRefMessageId(String ref)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

hasRefMsgId

protected boolean hasRefMsgId

refMsgId

protected String refMsgId
Constructor Detail

PubSubMessage

public PubSubMessage()
Method Detail

fromBytes

public abstract void fromBytes(byte[] bytes)
                        throws SerializationException
Description copied from interface: TwisterSerializable
Construct the object back from a previously serialized bytes.

Specified by:
fromBytes in interface TwisterSerializable
Throws:
SerializationException

getBytes

public abstract byte[] getBytes()
                         throws SerializationException
Description copied from interface: TwisterSerializable
Serialize the object and returns the bytes.

Specified by:
getBytes in interface TwisterSerializable
Returns:
byte[] of serialized object.
Throws:
SerializationException

getRefMessageId

public String getRefMessageId()

readRefIdIfAny

public void readRefIdIfAny(DataInputStream din)
                    throws IOException
Throws:
IOException

serializeRefId

public void serializeRefId(DataOutputStream dout)
                    throws IOException
Throws:
IOException

setRefMessageId

public void setRefMessageId(String ref)


For comments and suggestions please send e-mail to