All Classes
-
All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary Class Description AgentId AgentState BookKeeper Keeps track of offset and processed status and manages coordinates the import/retry handling.BookKeeper.PackageStatus BookKeeperConfig BookKeeperFactory CacheCallback ClearCallback CommandPoller DefaultDistributionLog Default implementation of aDistributionLogDefaultDistributionLog.LogLevel Log levelDefaultPrecondition Delay DiscoveryService Listens for discovery messages and tracks presence of Subscribers as well as the last processed offset of each Subscriber This component is only activated when there is at least one DistributionSubscriber agent configured.DistPublisherJMXMBean DistributedEventNotifierManager DistributedEventNotifierManager.Configuration DistributionEvent DistributionLogEventListener Listens to log message events (for errors) and package distributed events (for success) and logs both to the given DefaultDistributionLogDistributionMetricsService DistributionPublisher A Publisher SCD agent which produces messages to be consumed by aDistributionSubscriberagent.DistributionSubscriber A Subscriber SCD agent which consumes messages produced by aDistributionPublisheragent.ErrorListener ExponentialBackOff Retry with exponential backoff.IdleCheck JcrBinaryStore JMXRegistration JournalAvailableChecker JournalAvailableChecker.JournalCheckerConfiguration LocalStore LocalStoreJMX LocalStoreJMXMBean MessagingCacheCallback NoopIdle NoOpImportPostProcessor NoOpInvalidationProcessor OffsetQueue<T> A queue ofTitems indexed by offsets.PackageCleaner PackageCleanupTask The cleanup task fetches the head offset (the smallest) and the tail offset (the current biggest) on the package topic.PackageDistributedNotifier PackageFactoryConfiguration PackageHandling PackageMessageFactory PackageQueuedNotifier PackageRetries Holds package retries by agent namePackageStatusWatcher Precondition Extension point for checking if a package can be processed by a subscriber.Precondition.Decision PreConditionTimeoutException PublisherConfiguration PublisherConfigurationAvailable This service checks for DistributionPublisher agent configuration availability and registers the marker servicePublisherConfigurationAvailablewhen such configuration could be found.PubQueueProvider PubQueueProviderFactory PubQueueProviderPublisher Normally PubQueueProvider should be created per publish agent.QueueCacheSeeder QueuedCallback QueueItemFactory QueueState RangePoller SimpleDistributionResponse StagingPrecondition This is a precondition that watches status messages from other instances in order to confirm that a package can be processed.State Strings SubscriberConfiguration SubscriberIdle A DistributionSubscriber is considered ready when it is idle for more than the READY_IDLE_TIME_SECONDS at least once ; or when it is busy processing the same package for more than MAX_RETRIES times.SubscriberIdleCheck SubscriberReadyStore Topics Topics.TopicsConfiguration TopologyChangeHandler TopologyView TopologyViewDiff TopologyViewManager