path	# lines of code
src/main/java/org/apache/sling/distribution/journal/impl/precondition/DefaultPrecondition.java	9
src/main/java/org/apache/sling/distribution/journal/impl/precondition/PackageStatusWatcher.java	61
src/main/java/org/apache/sling/distribution/journal/impl/precondition/Precondition.java	5
src/main/java/org/apache/sling/distribution/journal/impl/precondition/StagingPrecondition.java	52
src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistPublisherJMX.java	76
src/main/java/org/apache/sling/distribution/journal/impl/publisher/PublisherConfiguration.java	17
src/main/java/org/apache/sling/distribution/journal/impl/publisher/RangePoller.java	74
src/main/java/org/apache/sling/distribution/journal/impl/publisher/MessagingCacheCallback.java	89
src/main/java/org/apache/sling/distribution/journal/impl/publisher/AgentState.java	41
src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageFactoryConfiguration.java	10
src/main/java/org/apache/sling/distribution/journal/impl/publisher/QueueCacheSeeder.java	80
src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistPublisherJMXMBean.java	7
src/main/java/org/apache/sling/distribution/journal/impl/publisher/SimpleDistributionResponse.java	43
src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java	249
src/main/java/org/apache/sling/distribution/journal/impl/publisher/PubQueueProviderPublisher.java	53
src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageDistributedNotifier.java	130
src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageMessageFactory.java	153
src/main/java/org/apache/sling/distribution/journal/impl/publisher/PackageQueuedNotifier.java	66
src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributedEventNotifierManager.java	102
src/main/java/org/apache/sling/distribution/journal/impl/discovery/TopologyView.java	74
src/main/java/org/apache/sling/distribution/journal/impl/discovery/DiscoveryService.java	131
src/main/java/org/apache/sling/distribution/journal/impl/discovery/TopologyViewManager.java	45
src/main/java/org/apache/sling/distribution/journal/impl/discovery/State.java	75
src/main/java/org/apache/sling/distribution/journal/impl/discovery/TopologyViewDiff.java	49
src/main/java/org/apache/sling/distribution/journal/impl/discovery/TopologyChangeHandler.java	6
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberReadyStore.java	12
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java	325
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/IdleCheck.java	7
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/NoopIdle.java	16
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/CommandPoller.java	53
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/PreConditionTimeoutException.java	7
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberIdleCheck.java	30
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberIdle.java	56
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberConfiguration.java	31
src/main/java/org/apache/sling/distribution/journal/impl/subscriber/Announcer.java	86
src/main/java/org/apache/sling/distribution/journal/impl/event/DistributionEvent.java	52
src/main/java/org/apache/sling/distribution/journal/shared/DistributionMetricsService.java	195
src/main/java/org/apache/sling/distribution/journal/shared/Topics.java	73
src/main/java/org/apache/sling/distribution/journal/shared/JournalAvailableChecker.java	112
src/main/java/org/apache/sling/distribution/journal/shared/NoOpImportPostProcessor.java	14
src/main/java/org/apache/sling/distribution/journal/shared/NoOpInvalidationProcessor.java	14
src/main/java/org/apache/sling/distribution/journal/shared/PublisherConfigurationAvailable.java	55
src/main/java/org/apache/sling/distribution/journal/shared/Strings.java	11
src/main/java/org/apache/sling/distribution/journal/shared/Delay.java	24
src/main/java/org/apache/sling/distribution/journal/shared/JournalAvailableServiceMarker.java	27
src/main/java/org/apache/sling/distribution/journal/shared/ExponentialBackOff.java	74
src/main/java/org/apache/sling/distribution/journal/shared/JMXRegistration.java	36
src/main/java/org/apache/sling/distribution/journal/shared/DefaultDistributionLog.java	99
src/main/java/org/apache/sling/distribution/journal/shared/LocalStoreJMXMBean.java	4
src/main/java/org/apache/sling/distribution/journal/shared/AgentId.java	45
src/main/java/org/apache/sling/distribution/journal/shared/DistributionLogEventListener.java	62
src/main/java/org/apache/sling/distribution/journal/bookkeeper/PackageRetries.java	20
src/main/java/org/apache/sling/distribution/journal/bookkeeper/ErrorListener.java	21
src/main/java/org/apache/sling/distribution/journal/bookkeeper/PackageHandler.java	78
src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeper.java	335
src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeperFactory.java	53
src/main/java/org/apache/sling/distribution/journal/bookkeeper/ContentPackageExtractor.java	101
src/main/java/org/apache/sling/distribution/journal/bookkeeper/AppliedEvent.java	32
src/main/java/org/apache/sling/distribution/journal/bookkeeper/LocalStoreJMX.java	62
src/main/java/org/apache/sling/distribution/journal/bookkeeper/LocalStore.java	100
src/main/java/org/apache/sling/distribution/journal/bookkeeper/BookKeeperConfig.java	60
src/main/java/org/apache/sling/distribution/journal/bookkeeper/PackageHandling.java	4
src/main/java/org/apache/sling/distribution/journal/bookkeeper/package-info.java	1
src/main/java/org/apache/sling/distribution/journal/queue/QueuedCallback.java	7
src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueProviderImpl.java	161
src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueProviderFactoryImpl.java	23
src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueCache.java	135
src/main/java/org/apache/sling/distribution/journal/queue/impl/QueueEntryFactory.java	42
src/main/java/org/apache/sling/distribution/journal/queue/impl/PubErrQueue.java	100
src/main/java/org/apache/sling/distribution/journal/queue/impl/OffsetQueueImpl.java	82
src/main/java/org/apache/sling/distribution/journal/queue/impl/OffsetQueueImplMBean.java	6
src/main/java/org/apache/sling/distribution/journal/queue/impl/EntryUtil.java	21
src/main/java/org/apache/sling/distribution/journal/queue/impl/QueueErrors.java	35
src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueue.java	175
src/main/java/org/apache/sling/distribution/journal/queue/OffsetQueue.java	19
src/main/java/org/apache/sling/distribution/journal/queue/QueueState.java	25
src/main/java/org/apache/sling/distribution/journal/queue/QueueItemFactory.java	73
src/main/java/org/apache/sling/distribution/journal/queue/PubQueueProvider.java	22
src/main/java/org/apache/sling/distribution/journal/queue/ClearCallback.java	6
src/main/java/org/apache/sling/distribution/journal/queue/CacheCallback.java	13
src/main/java/org/apache/sling/distribution/journal/queue/PubQueueProviderFactory.java	4
src/main/java/org/apache/sling/distribution/journal/queue/package-info.java	1
src/main/java/org/apache/sling/distribution/journal/binary/jcr/PackageCleaner.java	37
src/main/java/org/apache/sling/distribution/journal/binary/jcr/PackageCleanupTask.java	35
src/main/java/org/apache/sling/distribution/journal/binary/jcr/JcrBinaryStore.java	114