Package | Description |
---|---|
com.gigaspaces.dih.consumer | |
com.gigaspaces.dih.consumer.web |
Modifier and Type | Class and Description |
---|---|
class |
DefaultMessageCleanser |
Constructor and Description |
---|
GSKafkaConsumerThread(ConsumerConfiguration consumerConfiguration,
GSMessageExecutor messageExecutor,
GSMessageConverter messageConverter,
GSMessageCleanser messageCleanser,
GSAuditor auditor,
boolean populateDeletedObjectsTable,
String kafkaConsumerGroup,
String consumerId) |
Modifier and Type | Method and Description |
---|---|
GSMessageCleanser |
GSConsumerHandler.initCleanser() |
Copyright © GigaSpaces.