Package com.gigaspaces.dih.consumer.cr8

Class CR8MessageConverter

java.lang.Object

com.gigaspaces.dih.consumer.GSMessageConverter

com.gigaspaces.dih.consumer.cr8.CR8MessageConverter

public class CR8MessageConverter
extends GSMessageConverter

Constructor Summary

Constructors

Constructor	Description
CR8MessageConverter(ConversionMap conversionMap)

Method Summary

Modifier and Type	Method	Description
static GSInsertMessage	convertToInsertMessage(GSDataSourceMessage dataSourceMessage)
static GSUpdateMessage	convertToUpdateMessage(GSDataSourceMessage dataSourceMessage)
DataPipelineMessage	toGSMessage(KafkaMessage kafkaMessage, String pipelineName)

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

getConversionMap

Methods inherited from class java.lang.Object

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

Constructor Details

CR8MessageConverter

public CR8MessageConverter(ConversionMap conversionMap)

Method Details

toGSMessage

public DataPipelineMessage toGSMessage(KafkaMessage kafkaMessage,
 String pipelineName)

Specified by:

toGSMessage in class GSMessageConverter

convertToUpdateMessage

public static GSUpdateMessage convertToUpdateMessage(GSDataSourceMessage dataSourceMessage)

convertToInsertMessage

public static GSInsertMessage convertToInsertMessage(GSDataSourceMessage dataSourceMessage)