com.gigaspaces.dih.consumer

Class GSDataSourceMessage

java.lang.Object

com.gigaspaces.dih.consumer.GSDataSourceMessage

All Implemented Interfaces:

DataPipelineMessage

Direct Known Subclasses:

GSDeleteMessage, GSInsertMessage, GSUpdateMessage

public abstract class GSDataSourceMessage
extends Object
implements DataPipelineMessage

Constructor Summary

Constructors

Constructor and Description
GSDataSourceMessage(long messageID, String fullTypeName, String pipelineName)

Method Summary

Modifier and Type	Method and Description
abstract List<String>	getFields()
String	getFullTypeName()
long	getMessageID()
String	getPipelineName()
abstract Object	getValue(String field)
abstract Map<String,Object>	getValues()
abstract boolean	isDelete()
abstract boolean	isInsert()
abstract boolean	isUpdate()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.dih.consumer.DataPipelineMessage

isFullSync, isValidate

Constructor Detail

GSDataSourceMessage

public GSDataSourceMessage(long messageID,
                           String fullTypeName,
                           String pipelineName)

Method Detail

getFullTypeName

public String getFullTypeName()

getMessageID

public long getMessageID()

getPipelineName

public String getPipelineName()

getFields

public abstract List<String> getFields()

getValues

public abstract Map<String,Object> getValues()

getValue

public abstract Object getValue(String field)

isInsert

public abstract boolean isInsert()

Specified by:

isInsert in interface DataPipelineMessage

isDelete

public abstract boolean isDelete()

Specified by:

isDelete in interface DataPipelineMessage

isUpdate

public abstract boolean isUpdate()

Specified by:

isUpdate in interface DataPipelineMessage