public class CR8MessageConverter extends GSMessageConverter
Constructor and Description |
---|
CR8MessageConverter(ConversionMap conversionMap) |
Modifier and Type | Method and Description |
---|---|
static GSUpdateMessage |
convertToUpdateMessage(GSDataSourceMessage dataSourceMessage) |
DataPipelineMessage |
toGSMessage(KafkaMessage kafkaMessage,
String pipelineName) |
getConversionMap
public CR8MessageConverter(ConversionMap conversionMap)
public DataPipelineMessage toGSMessage(KafkaMessage kafkaMessage, String pipelineName)
toGSMessage
in class GSMessageConverter
public static GSUpdateMessage convertToUpdateMessage(GSDataSourceMessage dataSourceMessage)
Copyright © GigaSpaces.