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:
  • Constructor Details

    • CR8KafkaCommandMessage

      public CR8KafkaCommandMessage()
  • Method Details

    • 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