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 and Description
CR8MessageConverter(ConversionMap conversionMap)

Method Summary

Modifier and Type	Method and Description
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 Detail

CR8MessageConverter

public CR8MessageConverter(ConversionMap conversionMap)

Method Detail

toGSMessage

public DataPipelineMessage toGSMessage(KafkaMessage kafkaMessage,
                                       String pipelineName)

Specified by:

toGSMessage in class GSMessageConverter