com.gigaspaces.dih.consumer.cr8

Class CR8KafkaCommandMessage

java.lang.Object

com.gigaspaces.dih.consumer.cr8.CR8KafkaMessage

com.gigaspaces.dih.consumer.cr8.CR8KafkaCommandMessage

All Implemented Interfaces:

KafkaMessage, Serializable

public class CR8KafkaCommandMessage
extends CR8KafkaMessage

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CR8KafkaCommandMessage()

Method Summary

Modifier and Type	Method and Description
Map<String,String>	getChangedFieldsList()
String	getCommandCommitScn()
String	getCommandId()
String	getCommandScn()
String	getCommandSequence()
String	getCommandTimestamp()
String	getCommandType()
Map<String,String>	getConditionFieldsList()
String	getFullTypeName()
List<String>	getListChangedColumns()
String	getObjectDBName()
String	getObjectId()
String	getObjectSchemaName()
String	getRsId()
String	getTransactionId()
void	setChangedFieldsList(Map<String,String> changedFieldsList)
void	setCommandCommitScn(String commandCommitScn)
void	setCommandId(String commandId)
void	setCommandScn(String commandScn)
void	setCommandSequence(String commandSequence)
void	setCommandTimestamp(String commandTimestamp)
void	setCommandType(String commandType)
void	setConditionFieldsList(Map<String,String> conditionFieldsList)
void	setListChangedColumns(List<String> listChangedColumns)
void	setObjectDBName(String objectDBName)
void	setObjectId(String objectId)
void	setObjectSchemaName(String objectSchemaName)
void	setRsId(String rsId)
void	setTransactionId(String transactionId)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CR8KafkaCommandMessage

public CR8KafkaCommandMessage()

Method Detail

getCommandScn

public String getCommandScn()

setCommandScn

public void setCommandScn(String commandScn)

getCommandCommitScn

public String getCommandCommitScn()

setCommandCommitScn

public void setCommandCommitScn(String commandCommitScn)

getCommandSequence

public String getCommandSequence()

setCommandSequence

public void setCommandSequence(String commandSequence)

getTransactionId

public String getTransactionId()

setTransactionId

public void setTransactionId(String transactionId)

getRsId

public String getRsId()

setRsId

public void setRsId(String rsId)

getCommandId

public String getCommandId()

setCommandId

public void setCommandId(String commandId)

getCommandType

public String getCommandType()

setCommandType

public void setCommandType(String commandType)

getCommandTimestamp

public String getCommandTimestamp()

setCommandTimestamp

public void setCommandTimestamp(String commandTimestamp)

getObjectDBName

public String getObjectDBName()

setObjectDBName

public void setObjectDBName(String objectDBName)

getObjectSchemaName

public String getObjectSchemaName()

setObjectSchemaName

public void setObjectSchemaName(String objectSchemaName)

getObjectId

public String getObjectId()

setObjectId

public void setObjectId(String objectId)

getListChangedColumns

public List<String> getListChangedColumns()

setListChangedColumns

public void setListChangedColumns(List<String> listChangedColumns)

getChangedFieldsList

public Map<String,String> getChangedFieldsList()

setChangedFieldsList

public void setChangedFieldsList(Map<String,String> changedFieldsList)

getConditionFieldsList

public Map<String,String> getConditionFieldsList()

setConditionFieldsList

public void setConditionFieldsList(Map<String,String> conditionFieldsList)

getFullTypeName

public String getFullTypeName()

toString

public String toString()

Overrides:

toString in class Object