Package com.gigaspaces.dih.consumer

Class GSMessageConverter

java.lang.Object

com.gigaspaces.dih.consumer.GSMessageConverter

Direct Known Subclasses:

CR8MessageConverter

public abstract class GSMessageConverter
extends Object

Since:

16.1.0

Author:

Meshi Ruff, Yael Nahon Provide mapping between data source kafka messages and GSDataSourceMessage

Constructor Summary

Constructors

Constructor	Description
GSMessageConverter(ConversionMap conversionMap)

Method Summary

Modifier and Type	Method	Description
ConversionMap	getConversionMap()
abstract DataPipelineMessage	toGSMessage(KafkaMessage kafkaMessage, String streamName)

Methods inherited from class java.lang.Object

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

Constructor Details

GSMessageConverter

public GSMessageConverter(ConversionMap conversionMap)

Method Details

toGSMessage

public abstract DataPipelineMessage toGSMessage(KafkaMessage kafkaMessage,
 String streamName)

getConversionMap

public ConversionMap getConversionMap()