Path	Lines of Code
core/src/main/java/org/apache/ignite/activestore/ActiveCacheStore.java	155
core/src/main/java/org/apache/ignite/activestore/ClusterMode.java	4
core/src/main/java/org/apache/ignite/activestore/IdSequencer.java	5
core/src/main/java/org/apache/ignite/activestore/KeyValueListener.java	9
core/src/main/java/org/apache/ignite/activestore/SerializableProvider.java	5
core/src/main/java/org/apache/ignite/activestore/commons/ActiveStoreLifecycleService.java	27
core/src/main/java/org/apache/ignite/activestore/commons/BaseActiveStoreConfiguration.java	68
core/src/main/java/org/apache/ignite/activestore/commons/EndpointUtils.java	13
core/src/main/java/org/apache/ignite/activestore/commons/Lazy.java	49
core/src/main/java/org/apache/ignite/activestore/commons/ProxyService.java	22
core/src/main/java/org/apache/ignite/activestore/commons/Reference.java	6
core/src/main/java/org/apache/ignite/activestore/commons/UUIDFormat.java	7
core/src/main/java/org/apache/ignite/activestore/commons/injection/ActiveStoreIgniteCallable.java	9
core/src/main/java/org/apache/ignite/activestore/commons/injection/ActiveStoreIgniteRunnable.java	9
core/src/main/java/org/apache/ignite/activestore/commons/injection/ActiveStoreService.java	8
core/src/main/java/org/apache/ignite/activestore/commons/injection/DependencyContainer.java	67
core/src/main/java/org/apache/ignite/activestore/commons/injection/Injection.java	57
core/src/main/java/org/apache/ignite/activestore/commons/injection/LifecycleQueue.java	33
core/src/main/java/org/apache/ignite/activestore/commons/injection/ListOf.java	23
core/src/main/java/org/apache/ignite/activestore/commons/injection/PostCreationListener.java	43
core/src/main/java/org/apache/ignite/activestore/commons/retry/Retries.java	72
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryCallable.java	33
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryCallableAsyncOnCallback.java	26
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryFuture.java	54
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryRunnable.java	21
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryRunnableAsyncOnCallback.java	18
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryStrategy.java	74
core/src/main/java/org/apache/ignite/activestore/commons/serializer/JavaSerializer.java	13
core/src/main/java/org/apache/ignite/activestore/commons/serializer/Serializer.java	7
core/src/main/java/org/apache/ignite/activestore/commons/tasks/ExtendedScheduler.java	47
core/src/main/java/org/apache/ignite/activestore/commons/tasks/PeriodicCallTask.java	18
core/src/main/java/org/apache/ignite/activestore/commons/tasks/PeriodicTask.java	19
core/src/main/java/org/apache/ignite/activestore/commons/tasks/Scheduler.java	21
core/src/main/java/org/apache/ignite/activestore/commons/tasks/SimpleTask.java	11
core/src/main/java/org/apache/ignite/activestore/commons/tasks/Task.java	4
core/src/main/java/org/apache/ignite/activestore/impl/DataCapturerBusConfiguration.java	149
core/src/main/java/org/apache/ignite/activestore/impl/DataRecoveryConfig.java	44
core/src/main/java/org/apache/ignite/activestore/impl/InMemoryIdSequencer.java	13
core/src/main/java/org/apache/ignite/activestore/impl/config/EmptyFuture.java	31
core/src/main/java/org/apache/ignite/activestore/impl/config/FutureUnsubscribeOnFail.java	47
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCManager.java	8
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCManagerImpl.java	54
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCService.java	4
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCServiceImpl.java	95
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCUpdater.java	6
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaConfig.java	55
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaMetadata.java	17
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersManager.java	6
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersManagerImpl.java	54
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersManagerUpdater.java	105
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersUpdater.java	8
core/src/main/java/org/apache/ignite/activestore/impl/config/ResubscribeTask.java	19
core/src/main/java/org/apache/ignite/activestore/impl/config/SimpleSuperCluster.java	19
core/src/main/java/org/apache/ignite/activestore/impl/config/SuperCluster.java	11
core/src/main/java/org/apache/ignite/activestore/impl/config/UnsubscribeTask.java	15
core/src/main/java/org/apache/ignite/activestore/impl/config/UnsubscriberOnFailWrapper.java	7
core/src/main/java/org/apache/ignite/activestore/impl/config/UnsubscriberOnFailWrapperImpl.java	21
core/src/main/java/org/apache/ignite/activestore/impl/config/UpdateConfigurationTask.java	17
core/src/main/java/org/apache/ignite/activestore/impl/kafka/ConsumerProxyRetry.java	322
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaFactory.java	10
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaFactoryImpl.java	25
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaIdSequencer.java	57
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaIdSequencerFactory.java	19
core/src/main/java/org/apache/ignite/activestore/impl/kafka/ProducerProxyRetry.java	102
core/src/main/java/org/apache/ignite/activestore/impl/publisher/ActiveCacheStoreService.java	23
core/src/main/java/org/apache/ignite/activestore/impl/publisher/ActiveCacheStoreServiceImpl.java	37
core/src/main/java/org/apache/ignite/activestore/impl/publisher/AllReplicasRegisterTask.java	19
core/src/main/java/org/apache/ignite/activestore/impl/publisher/CommandServiceImpl.java	26
core/src/main/java/org/apache/ignite/activestore/impl/publisher/Commander.java	128
core/src/main/java/org/apache/ignite/activestore/impl/publisher/CommanderService.java	57
core/src/main/java/org/apache/ignite/activestore/impl/publisher/LocalKafkaKVListener.java	32
core/src/main/java/org/apache/ignite/activestore/impl/publisher/LocalKafkaProducer.java	43
core/src/main/java/org/apache/ignite/activestore/impl/publisher/LocalReconciliationWritersManager.java	60
core/src/main/java/org/apache/ignite/activestore/impl/publisher/PublisherKafkaService.java	39
core/src/main/java/org/apache/ignite/activestore/impl/publisher/PublisherReplicaService.java	41
core/src/main/java/org/apache/ignite/activestore/impl/publisher/PublisherUpdater.java	29
core/src/main/java/org/apache/ignite/activestore/impl/publisher/Reconciler.java	107
core/src/main/java/org/apache/ignite/activestore/impl/publisher/ReconciliationWriter.java	52
core/src/main/java/org/apache/ignite/activestore/impl/publisher/RegisterReplicaTask.java	23
core/src/main/java/org/apache/ignite/activestore/impl/publisher/RemoteKafkaProducer.java	51
core/src/main/java/org/apache/ignite/activestore/impl/publisher/Resubscriber.java	21
core/src/main/java/org/apache/ignite/activestore/impl/publisher/StartReconciliationTask.java	15
core/src/main/java/org/apache/ignite/activestore/impl/publisher/StopReconciliationTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/publisher/SynchronousPublisher.java	59
core/src/main/java/org/apache/ignite/activestore/impl/publisher/TransactionalKafkaProducer.java	43
core/src/main/java/org/apache/ignite/activestore/impl/publisher/UnsubscriptionNotificationTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/AbstractIgniteCommitter.java	33
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/BufferOverflowCondition.java	4
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/BufferOverflowConditionPeriodicTask.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/CommitOffsetsPeriodicTask.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/DeserializerClosure.java	25
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/DoneNotifier.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/FullCommitHandler.java	26
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/IgniteCommitter.java	24
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/KafkaHelper.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/LocalKafkaWriter.java	28
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/LoggingErrorHandler.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/OffsetCalculator.java	58
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/OffsetHolder.java	16
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/OnKafkaStop.java	21
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/ParallelIgniteCommitter.java	154
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/RebalanceListener.java	22
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SimpleBufferOverflowCondition.java	11
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SubscriberConsumer.java	175
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SubscriberConsumerService.java	7
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SubscriberConsumerServiceImpl.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/TransactionWrapper.java	43
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/TransactionsBuffer.java	83
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/TransactionsBufferHolder.java	8
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerMetadataRequest.java	16
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerPingCheckPeriodicTask.java	10
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerPingCheckStrategy.java	4
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerPingManager.java	61
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerResumeRequest.java	16
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerTask.java	18
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DefaultConsumerPingCheckStrategy.java	14
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DefaultGapDetectionStrategy.java	37
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DenseCommittedIdSavePeriodicTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DoneTask.java	21
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/GapDetectionStrategy.java	4
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/KafkaResurrectionCheckTask.java	42
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/Lead.java	230
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadContextLoader.java	104
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlanner.java	230
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlanningState.java	80
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadResponse.java	50
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadService.java	18
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadServiceImpl.java	46
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadServiceProxyRetry.java	114
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LoaderCurrentlyFinishedTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LocalLeadContextLoader.java	95
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LocalLeadContextLoaderManager.java	48
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/MainHeartbeatPeriodicTask.java	42
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/MergeHelper.java	95
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/NotifyTask.java	30
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ReconciliationState.java	6
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ReconciliationStateImpl.java	26
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/TestReconciliationState.java	14
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/TxInfo.java	26
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/UpdateInitialContextTask.java	16
core/src/main/java/org/apache/ignite/activestore/impl/transactions/JointTxScope.java	57
core/src/main/java/org/apache/ignite/activestore/impl/transactions/LinearTransactionDataIterator.java	35
core/src/main/java/org/apache/ignite/activestore/impl/transactions/LinearTransactionScopeIterator.java	30
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMessage.java	10
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMessageBuilder.java	24
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMessageUtil.java	12
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMetadata.java	23
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMetadataBuilder.java	22
core/src/main/java/org/apache/ignite/activestore/impl/util/AtomicsHelper.java	46
core/src/main/java/org/apache/ignite/activestore/impl/util/ClusterGroupService.java	46
core/src/main/java/org/apache/ignite/activestore/impl/util/FileUtils.java	24
core/src/main/java/org/apache/ignite/activestore/impl/util/PropertiesUtil.java	13
core/src/main/java/org/apache/ignite/activestore/publisher/CommandService.java	10
core/src/main/java/org/apache/ignite/activestore/subscriber/Committer.java	9
core/src/main/java/org/apache/ignite/activestore/subscriber/TransactionSupplier.java	7
core/src/main/java/org/apache/ignite/activestore/transactions/TransactionDataIterator.java	4
core/src/main/java/org/apache/ignite/activestore/transactions/TransactionScopeIterator.java	8