Uses of Class
org.openspaces.admin.di.ConsumerConfiguration

Packages that use ConsumerConfiguration

Package	Description
com.gigaspaces.dih.consumer
com.gigaspaces.dih.consumer.web
org.openspaces.admin.di

Uses of ConsumerConfiguration in com.gigaspaces.dih.consumer

Methods in com.gigaspaces.dih.consumer with parameters of type ConsumerConfiguration

Modifier and Type	Method and Description
void	GSMessageExecutor.executeDelete(GSDeleteMessage deleteMessage, ConsumerConfiguration consumerConfiguration, boolean populateDeletedObjectsTable)
void	GSMessageExecutorImpl.executeDelete(GSDeleteMessage deleteMessage, ConsumerConfiguration consumerConfiguration, boolean populateDeletedObjectsTable)
void	GSMessageExecutor.executeFullSyncBatch(List<GSInsertMessage> insertMessages, ConsumerConfiguration consumerConfiguration)
void	GSMessageExecutorImpl.executeFullSyncBatch(List<GSInsertMessage> insertMessages, ConsumerConfiguration consumerConfiguration)
void	GSMessageExecutor.executeInsert(GSInsertMessage insertMessage, ConsumerConfiguration consumerConfiguration)
void	GSMessageExecutorImpl.executeInsert(GSInsertMessage insertMessage, ConsumerConfiguration consumerConfiguration)
void	GSMessageExecutor.executeUpdate(GSUpdateMessage updateMessage, ConsumerConfiguration consumerConfiguration)
void	GSMessageExecutorImpl.executeUpdate(GSUpdateMessage updateMessage, ConsumerConfiguration consumerConfiguration)

Constructors in com.gigaspaces.dih.consumer with parameters of type ConsumerConfiguration

Constructor and Description
GSKafkaConsumerThread(ConsumerConfiguration consumerConfiguration, GSMessageExecutor messageExecutor, GSMessageConverter messageConverter, GSMessageCleanser messageCleanser, GSAuditor auditor, boolean populateDeletedObjectsTable, String kafkaConsumerGroup, String consumerId, Callback triggerFullSyncConsumerGracefulShutdown, Semaphore sem)

Uses of ConsumerConfiguration in com.gigaspaces.dih.consumer.web

Methods in com.gigaspaces.dih.consumer.web that return ConsumerConfiguration

Modifier and Type	Method and Description
ConsumerConfiguration	GSConsumerHandler.getConsumerConfigFromZK()

Methods in com.gigaspaces.dih.consumer.web with parameters of type ConsumerConfiguration

Modifier and Type	Method and Description
void	GSConsumerHandler.init(GigaSpace gigaSpace, String puName, ConsumerConfiguration consumerConfigFromZK)
void	GSConsumerHandler.saveConsumerConfigToZK(ConsumerConfiguration consumerConfiguration)
void	GSConsumerHandler.setConsumerConfiguration(ConsumerConfiguration consumerConfiguration)

Uses of ConsumerConfiguration in org.openspaces.admin.di

Methods in org.openspaces.admin.di that return ConsumerConfiguration

Modifier and Type	Method and Description
static ConsumerConfiguration	ConsumerConfiguration.fromJson(String json)