Uses of Interface
com.gigaspaces.dih.consumer.DataPipelineMessage

Packages that use DataPipelineMessage

Package	Description
com.gigaspaces.dih.consumer
com.gigaspaces.dih.consumer.cr8

Uses of DataPipelineMessage in com.gigaspaces.dih.consumer

Classes in com.gigaspaces.dih.consumer that implement DataPipelineMessage

Modifier and Type	Class	Description
class	GSDataSourceMessage
class	GSDeleteMessage
class	GSFullSyncIndicatorMessage
class	GSInsertMessage
class	GSUpdateMessage
class	GSValidationMessage

Methods in com.gigaspaces.dih.consumer that return DataPipelineMessage

Modifier and Type	Method	Description
abstract DataPipelineMessage	GSMessageConverter.toGSMessage(KafkaMessage kafkaMessage, String streamName)

Uses of DataPipelineMessage in com.gigaspaces.dih.consumer.cr8

Methods in com.gigaspaces.dih.consumer.cr8 that return DataPipelineMessage

Modifier and Type	Method	Description
DataPipelineMessage	CR8MessageConverter.toGSMessage(KafkaMessage kafkaMessage, String pipelineName)