Package | Description |
---|---|
com.gigaspaces.dih.consumer |
Modifier and Type | Method and Description |
---|---|
void |
GSMessageExecutor.executeFullSyncIndicator(GSFullSyncIndicatorMessage message,
Callback triggerFullSyncConsumerGracefulShutdown) |
void |
GSMessageExecutorImpl.executeFullSyncIndicator(GSFullSyncIndicatorMessage message,
Callback triggerFullSyncConsumerGracefulShutdown) |
Constructor and Description |
---|
GSKafkaConsumerThread(ConsumerConfiguration consumerConfiguration,
GSMessageExecutor messageExecutor,
GSMessageConverter messageConverter,
GSMessageCleanser messageCleanser,
GSAuditor auditor,
boolean populateDeletedObjectsTable,
String kafkaConsumerGroup,
String consumerId,
Callback triggerFullSyncConsumerGracefulShutdown,
Semaphore sem) |
Copyright © GigaSpaces.