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

Method Summary

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

GSMessageConverter

public GSMessageConverter(ConversionMap conversionMap)

Method Detail

toGSMessage

public abstract DataPipelineMessage toGSMessage(KafkaMessage kafkaMessage,
                                                String streamName)

getConversionMap

public ConversionMap getConversionMap()