Uses of Class
org.openspaces.admin.di.ConsumerConfiguration
Packages that use ConsumerConfiguration
Package
Description
-
Uses of ConsumerConfiguration in com.gigaspaces.dih.consumer
Methods in com.gigaspaces.dih.consumer with parameters of type ConsumerConfigurationModifier and TypeMethodDescriptionvoidGSMessageExecutor.executeDelete(GSDeleteMessage deleteMessage, ConsumerConfiguration consumerConfiguration, boolean populateDeletedObjectsTable) voidGSMessageExecutorImpl.executeDelete(GSDeleteMessage deleteMessage, ConsumerConfiguration consumerConfiguration, boolean populateDeletedObjectsTable) voidGSMessageExecutor.executeFullSyncBatch(List<GSInsertMessage> insertMessages, ConsumerConfiguration consumerConfiguration) voidGSMessageExecutorImpl.executeFullSyncBatch(List<GSInsertMessage> insertMessages, ConsumerConfiguration consumerConfiguration) voidGSMessageExecutor.executeInsert(GSInsertMessage insertMessage, ConsumerConfiguration consumerConfiguration) voidGSMessageExecutorImpl.executeInsert(GSInsertMessage insertMessage, ConsumerConfiguration consumerConfiguration) voidGSMessageExecutor.executeUpdate(GSUpdateMessage updateMessage, ConsumerConfiguration consumerConfiguration) voidGSMessageExecutorImpl.executeUpdate(GSUpdateMessage updateMessage, ConsumerConfiguration consumerConfiguration) Constructors in com.gigaspaces.dih.consumer with parameters of type ConsumerConfigurationModifierConstructorDescriptionGSKafkaConsumerThread(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 ConsumerConfigurationMethods in com.gigaspaces.dih.consumer.web with parameters of type ConsumerConfigurationModifier and TypeMethodDescriptionvoidGSConsumerHandler.init(GigaSpace gigaSpace, String puName, ConsumerConfiguration consumerConfigFromZK) voidGSConsumerHandler.saveConsumerConfigToZK(ConsumerConfiguration consumerConfiguration) voidGSConsumerHandler.setConsumerConfiguration(ConsumerConfiguration consumerConfiguration) -
Uses of ConsumerConfiguration in org.openspaces.admin.di
Methods in org.openspaces.admin.di that return ConsumerConfiguration