com.gigaspaces.dih.consumer

Class GSInsertMessage

java.lang.Object

com.gigaspaces.dih.consumer.GSDataSourceMessage

com.gigaspaces.dih.consumer.GSInsertMessage

All Implemented Interfaces:

DataPipelineMessage

public class GSInsertMessage
extends GSDataSourceMessage

Constructor Summary

Constructors

Constructor and Description
GSInsertMessage(long messageId, String fullTypeName, String pipelineName)

Method Summary

Modifier and Type	Method and Description
List<String>	getFields()
Object	getValue(String field)
Map<String,Object>	getValues()
boolean	isDelete()
boolean	isInsert()
boolean	isUpdate()
void	setValue(String name, Object value)
GSInsertMessage	setValues(Map<String,Object> values)
String	toString()

Methods inherited from class com.gigaspaces.dih.consumer.GSDataSourceMessage

getFullTypeName, getMessageID, getPipelineName

Methods inherited from class java.lang.Object

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

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

isValidate

Constructor Detail

GSInsertMessage

public GSInsertMessage(long messageId,
                       String fullTypeName,
                       String pipelineName)

Method Detail

getValues

public Map<String,Object> getValues()

Specified by:

getValues in class GSDataSourceMessage

getFields

public List<String> getFields()

Specified by:

getFields in class GSDataSourceMessage

getValue

public Object getValue(String field)

Specified by:

getValue in class GSDataSourceMessage

setValue

public void setValue(String name,
                     Object value)

setValues

public GSInsertMessage setValues(Map<String,Object> values)

isInsert

public boolean isInsert()

Specified by:

isInsert in interface DataPipelineMessage

Specified by:

isInsert in class GSDataSourceMessage

isDelete

public boolean isDelete()

Specified by:

isDelete in interface DataPipelineMessage

Specified by:

isDelete in class GSDataSourceMessage

isUpdate

public boolean isUpdate()

Specified by:

isUpdate in interface DataPipelineMessage

Specified by:

isUpdate in class GSDataSourceMessage

toString

public String toString()

Overrides:

toString in class Object