Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- ACCEPT - Enum constant in enum org.apache.sling.distribution.journal.impl.precondition.Precondition.Decision
- ACCEPTABLE_AGE_DIFF_MS - Static variable in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReady
- activate() - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStoreJMX
- activate() - Method in class org.apache.sling.distribution.journal.impl.precondition.StagingPrecondition
- activate(PackageFactoryConfiguration) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
- activate(SubscriberConfiguration, BundleContext, Map<String, Object>) - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
- activate(Topics.TopicsConfiguration) - Method in class org.apache.sling.distribution.journal.shared.Topics
- activate(BundleContext) - Method in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- activate(BundleContext) - Method in class org.apache.sling.distribution.journal.shared.PublisherConfigurationAvailable
- AgentId - Class in org.apache.sling.distribution.journal.shared
- AgentId(String) - Constructor for class org.apache.sling.distribution.journal.shared.AgentId
- AgentId(String, String) - Constructor for class org.apache.sling.distribution.journal.shared.AgentId
- agentNames() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- AgentState - Class in org.apache.sling.distribution.journal.impl.publisher
- await(long) - Method in class org.apache.sling.distribution.journal.shared.Delay
B
- BookKeeper - Class in org.apache.sling.distribution.journal.bookkeeper
-
Keeps track of offset and processed status and manages coordinates the import/retry handling.
- BookKeeper(ResourceResolverFactory, SubscriberMetrics, PackageHandler, EventAdmin, Consumer<PackageStatusMessage>, Consumer<LogMessage>, BookKeeperConfig, ImportPreProcessor, ImportPostProcessor, InvalidationProcessor) - Constructor for class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- BookKeeper.PackageStatus - Class in org.apache.sling.distribution.journal.bookkeeper
- BookKeeperConfig - Class in org.apache.sling.distribution.journal.bookkeeper
- BookKeeperConfig(String, String, boolean, int, PackageHandling, String, boolean) - Constructor for class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- BookKeeperFactory - Class in org.apache.sling.distribution.journal.bookkeeper
- BookKeeperFactory() - Constructor for class org.apache.sling.distribution.journal.bookkeeper.BookKeeperFactory
- busy(int, long) - Method in interface org.apache.sling.distribution.journal.impl.subscriber.IdleCheck
-
Called when processing of a message starts
- busy(int, long) - Method in class org.apache.sling.distribution.journal.impl.subscriber.NoopIdle
- busy(int, long) - Method in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReady
-
Called when processing of a message starts
C
- CacheCallback - Interface in org.apache.sling.distribution.journal.queue
- canProcess(String, long) - Method in class org.apache.sling.distribution.journal.impl.precondition.DefaultPrecondition
- canProcess(String, long) - Method in interface org.apache.sling.distribution.journal.impl.precondition.Precondition
-
Checks if a package can be processed
- canProcess(String, long) - Method in class org.apache.sling.distribution.journal.impl.precondition.StagingPrecondition
- cardinal - Variable in enum org.apache.sling.distribution.journal.shared.DefaultDistributionLog.LogLevel
- changed(TopologyViewDiff) - Method in interface org.apache.sling.distribution.journal.impl.discovery.TopologyChangeHandler
-
Invoked by the framework when the TopologyView has changed.
- changed(TopologyViewDiff) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
- clear(long) - Method in interface org.apache.sling.distribution.journal.queue.ClearCallback
- clear(String) - Method in class org.apache.sling.distribution.journal.bookkeeper.PackageRetries
- ClearCallback - Interface in org.apache.sling.distribution.journal.queue
- clearPackageRetriesOnSuccess(PackageMessage) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
-
This method clears the packageRetries storage for a given package and emits metrics on the success of the retry.
- close() - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStoreJMX
- close() - Method in class org.apache.sling.distribution.journal.impl.precondition.PackageStatusWatcher
- close() - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
- close() - Method in class org.apache.sling.distribution.journal.impl.publisher.QueueCacheSeeder
- close() - Method in class org.apache.sling.distribution.journal.impl.subscriber.CommandPoller
- close() - Method in class org.apache.sling.distribution.journal.impl.subscriber.NoopIdle
- close() - Method in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberIdleCheck
- close() - Method in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReady
- close() - Method in class org.apache.sling.distribution.journal.shared.DistributionLogEventListener
- close() - Method in class org.apache.sling.distribution.journal.shared.ExponentialBackOff
- close() - Method in class org.apache.sling.distribution.journal.shared.JMXRegistration
- COMMAND_TOPIC - Static variable in class org.apache.sling.distribution.journal.shared.Topics
- CommandPoller - Class in org.apache.sling.distribution.journal.impl.subscriber
- CommandPoller(MessagingProvider, Topics, String, String, Runnable) - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.CommandPoller
- commandTopic() - Element in annotation type org.apache.sling.distribution.journal.shared.Topics.TopicsConfiguration
- COMMIT_AFTER_NUM_SKIPPED - Static variable in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- compareTo(Tag) - Method in interface org.apache.sling.distribution.journal.metrics.Tag
- contentPackageExtractorOverwritePrimaryTypesOfFolders() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- create(CacheCallback) - Method in interface org.apache.sling.distribution.journal.queue.PubQueueProviderFactory
- create(DistributionPackageBuilder, ResourceResolver, String, DistributionRequest) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
- create(DistributionPackageBuilder, BookKeeperConfig, Consumer<PackageStatusMessage>, Consumer<LogMessage>, SubscriberMetrics) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperFactory
- createConsumer(MessageHandler<PackageMessage>) - Method in class org.apache.sling.distribution.journal.impl.publisher.MessagingCacheCallback
- createConsumer(MessageHandler<PackageMessage>) - Method in interface org.apache.sling.distribution.journal.queue.CacheCallback
- createTest(DistributionPackageBuilder, ResourceResolver, DistributionRequest, String) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
- currentRetries(Supplier<Integer>) - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
D
- deactivate() - Method in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- deactivate() - Method in class org.apache.sling.distribution.journal.impl.precondition.StagingPrecondition
- deactivate() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributedEventNotifierManager
- deactivate() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- deactivate() - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
- deactivate() - Method in class org.apache.sling.distribution.journal.impl.publisher.PubQueueProviderPublisher
- deactivate() - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
- deactivate() - Method in class org.apache.sling.distribution.journal.shared.PublisherConfigurationAvailable
- debug(String, Object...) - Method in class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- DEBUG - Enum constant in enum org.apache.sling.distribution.journal.shared.DefaultDistributionLog.LogLevel
- deduplicateEvent() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.DistributedEventNotifierManager.Configuration
- DEFAULT_QUEUE_SIZE_LIMIT - Static variable in annotation type org.apache.sling.distribution.journal.impl.publisher.PublisherConfiguration
- DEFAULT_SEED_DELAY_SECONDS - Static variable in class org.apache.sling.distribution.journal.impl.publisher.RangePoller
- DefaultDistributionLog - Class in org.apache.sling.distribution.journal.shared
-
Default implementation of a
DistributionLog
- DefaultDistributionLog(String, Class<?>, DefaultDistributionLog.LogLevel) - Constructor for class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- DefaultDistributionLog.LogLevel - Enum in org.apache.sling.distribution.journal.shared
-
Log level
- DefaultPrecondition - Class in org.apache.sling.distribution.journal.impl.precondition
- DefaultPrecondition() - Constructor for class org.apache.sling.distribution.journal.impl.precondition.DefaultPrecondition
- DefaultTag - Class in org.apache.sling.distribution.journal.metrics
- DefaultTag(String, String) - Constructor for class org.apache.sling.distribution.journal.metrics.DefaultTag
- Delay - Class in org.apache.sling.distribution.journal.shared
- Delay() - Constructor for class org.apache.sling.distribution.journal.shared.Delay
- deleted(String) - Method in class org.apache.sling.distribution.journal.shared.PublisherConfigurationAvailable
- DISCOVERY_TOPIC - Static variable in class org.apache.sling.distribution.journal.shared.Topics
- DiscoveryService - Class in org.apache.sling.distribution.journal.impl.discovery
-
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.
- DiscoveryService() - Constructor for class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- DiscoveryService(MessagingProvider, TopologyChangeHandler, Topics, EventAdmin) - Constructor for class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- discoveryTopic() - Element in annotation type org.apache.sling.distribution.journal.shared.Topics.TopicsConfiguration
- DistributedEventNotifierManager - Class in org.apache.sling.distribution.journal.impl.publisher
- DistributedEventNotifierManager(BundleContext, DistributedEventNotifierManager.Configuration, EventAdmin, PubQueueProvider, MessagingProvider, Topics, ResourceResolverFactory, EventHandler) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.DistributedEventNotifierManager
-
Register the package distributed event notifier service on all or only the leader instance in a cluster according to the configuration.
- DistributedEventNotifierManager.Configuration - Annotation Type in org.apache.sling.distribution.journal.impl.publisher
- DistributionEvent - Class in org.apache.sling.distribution.journal.impl.event
- DistributionLogEventListener - Class in org.apache.sling.distribution.journal.shared
-
Listens to log message events (for errors) and package distributed events (for success) and logs both to the given DefaultDistributionLog
- DistributionLogEventListener(BundleContext, DefaultDistributionLog, String) - Constructor for class org.apache.sling.distribution.journal.shared.DistributionLogEventListener
- DistributionPublisher - Class in org.apache.sling.distribution.journal.impl.publisher
-
A Publisher SCD agent which produces messages to be consumed by a
DistributionSubscriber
agent. - DistributionPublisher(MessagingProvider, DistributionPackageBuilder, DiscoveryService, PackageMessageFactory, EventAdmin, Topics, MetricsService, PubQueueProvider, Condition, PublisherConfiguration, BundleContext) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- DistributionSubscriber - Class in org.apache.sling.distribution.journal.impl.subscriber
-
A Subscriber SCD agent which consumes messages produced by a
DistributionPublisher
agent. - DistributionSubscriber() - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
- DOMAIN - Static variable in class org.apache.sling.distribution.journal.shared.JMXRegistration
E
- editable() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- ensureEvent() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.DistributedEventNotifierManager.Configuration
- equals(Object) - Method in class org.apache.sling.distribution.journal.impl.discovery.State
-
Indicates whether some other State is "equal to" this one.
- equals(Object) - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
- equals(Object) - Method in class org.apache.sling.distribution.journal.metrics.DefaultTag
- error(String, Object...) - Method in class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- ERROR - Enum constant in enum org.apache.sling.distribution.journal.shared.DefaultDistributionLog.LogLevel
- ErrorListener - Class in org.apache.sling.distribution.journal.bookkeeper
- ErrorListener() - Constructor for class org.apache.sling.distribution.journal.bookkeeper.ErrorListener
- escapeTopicName(URI, String) - Static method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
- EVENT_TOPIC - Static variable in class org.apache.sling.distribution.journal.shared.Topics
- eventPackageCreated(PackageMessage, String) - Static method in class org.apache.sling.distribution.journal.impl.event.DistributionEvent
- eventPackageDistributed(DistributionQueueItem, String) - Static method in class org.apache.sling.distribution.journal.impl.event.DistributionEvent
- eventPackageQueued(PackageMessage, String) - Static method in class org.apache.sling.distribution.journal.impl.event.DistributionEvent
- eventTopic() - Element in annotation type org.apache.sling.distribution.journal.shared.Topics.TopicsConfiguration
- execute() - Method in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberIdleCheck
- execute(ResourceResolver, DistributionRequest) - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- exponential(long, long) - Static method in class org.apache.sling.distribution.journal.shared.Delay
- ExponentialBackOff - Class in org.apache.sling.distribution.journal.shared
-
Retry with exponential backoff.
- ExponentialBackOff(long, long, boolean, Runnable) - Constructor for class org.apache.sling.distribution.journal.shared.ExponentialBackOff
- Extract - Enum constant in enum org.apache.sling.distribution.journal.bookkeeper.PackageHandling
F
- FACTORY_PID - Static variable in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- fetchRange() - Method in class org.apache.sling.distribution.journal.impl.publisher.RangePoller
- fetchRange(long, long) - Method in class org.apache.sling.distribution.journal.impl.publisher.MessagingCacheCallback
- fetchRange(long, long) - Method in interface org.apache.sling.distribution.journal.queue.CacheCallback
- forceReadyMillies() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- fromPackage(FullMessage<PackageMessage>) - Static method in class org.apache.sling.distribution.journal.queue.QueueItemFactory
- fromPackage(MessageInfo, PackageMessage, boolean) - Static method in class org.apache.sling.distribution.journal.queue.QueueItemFactory
G
- get(String) - Method in class org.apache.sling.distribution.journal.bookkeeper.PackageRetries
- getAcceptedRequests() - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Meter of requests returning an
DistributionRequestState.ACCEPTED
state. - getAgentId() - Method in class org.apache.sling.distribution.journal.shared.AgentId
- getAgentName() - Method in class org.apache.sling.distribution.journal.shared.AgentId
- getBuildPackageDuration() - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Timer capturing the duration in ms of building a content package
- getClearCallback() - Method in class org.apache.sling.distribution.journal.queue.QueueState
- getCommandTopic() - Method in class org.apache.sling.distribution.journal.shared.Topics
- getCurrentView() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyViewManager
- getDiscoveryTopic() - Method in class org.apache.sling.distribution.journal.shared.Topics
- getDistributionInfo() - Method in class org.apache.sling.distribution.journal.impl.publisher.SimpleDistributionResponse
- getDroppedRequests() - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Meter of requests returning an
DistributionRequestState.DROPPED
state. - getEnqueuePackageDuration() - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Timer capturing the duration in ms of adding a package to the queue
- getEventTopic() - Method in class org.apache.sling.distribution.journal.shared.Topics
- getExportedPackageSize() - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Histogram of the exported content package size in Bytes.
- getFailedPackageImports() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Meter of failures to import packages.
- getHeadItem() - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
-
Return the item with the smallest offset in the queue.
- getHeadItems(int, int) - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
-
Return #limit items after skipping #skip items from the queue.
- getHeadOffset() - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
- getHeadRetries() - Method in class org.apache.sling.distribution.journal.queue.QueueState
- getImportedPackageDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Timer capturing the duration in ms of successful packages import operations.
- getImportedPackageSize() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Histogram of the imported content package size in Byte.
- getImportPostProcessDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getImportPostProcessRequest() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getImportPostProcessSuccess() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getImportPreProcessDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getImportPreProcessRequest() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getImportPreProcessSuccess() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getInvalidationProcessDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getInvalidationProcessRequest() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getInvalidationProcessSuccess() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getItem(long) - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
-
Return the item at the given #offset.
- getItemsBufferSize() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Counter of the package buffer size on the subscriber.
- getKey() - Method in class org.apache.sling.distribution.journal.metrics.DefaultTag
- getKey() - Method in interface org.apache.sling.distribution.journal.metrics.Tag
- getLastErrorMessage() - Method in class org.apache.sling.distribution.journal.bookkeeper.ErrorListener
- getLastProcessedOffset() - Method in class org.apache.sling.distribution.journal.queue.QueueState
- getLines() - Method in class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- getLog() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- getMaxQueueSize(String) - Method in interface org.apache.sling.distribution.journal.queue.PubQueueProvider
-
Get maximum size of all queues for a pubAgentName
- getMaxRetries() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- getMaxRetries() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- getMaxRetries() - Method in class org.apache.sling.distribution.journal.queue.QueueState
- getMessage() - Method in class org.apache.sling.distribution.journal.impl.publisher.SimpleDistributionResponse
- getMetricName(String, List<Tag>) - Static method in class org.apache.sling.distribution.journal.metrics.TaggedMetrics
- getMetricName(String, Tag) - Static method in class org.apache.sling.distribution.journal.metrics.TaggedMetrics
- getMinOffsetByPubAgentName() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
-
Return the map of min offset per publisher agent
- getMinOffsetQueue(long) - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
-
Return an
OffsetQueue
offset queue which contains all the items from the current queue at an offset greater or equal to #minOffset. - getName() - Method in class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- getName() - Method in class org.apache.sling.distribution.journal.shared.PublisherConfigurationAvailable
- getOffset() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- getOffsetQueue(String, long) - Method in interface org.apache.sling.distribution.journal.queue.PubQueueProvider
- getPackageDistributedDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Timer capturing the duration in ms of distributing a distribution package.
- getPackageHandling() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- getPackageJournalDistributionDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Timer capturing the duration in ms that a package spent in the distribution journal.
- getPackageNodeName() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- getPackageRetries() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- getPackageStatusCounter(PackageStatusMessage.Status) - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Counter for all the different package status.
- getPackageTopic() - Method in class org.apache.sling.distribution.journal.shared.Topics
- getPermanentImportErrors() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getProcessedOffsets() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyViewDiff
-
Return the map of the processed offsets, from the old and new view, per publisher agent.
- getProcessQueueItemDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Timer capturing the duration in ms of processing a queue item.
- getPubAgentName() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- getQueue(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- getQueue(String, String) - Method in interface org.apache.sling.distribution.journal.queue.PubQueueProvider
- getQueueAccessErrorCount() - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Counter of queue access errors.
- getQueueCacheFetchCount() - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
-
Counter of fetch operations to feed the queue cache.
- getQueuedNotifier() - Method in interface org.apache.sling.distribution.journal.queue.PubQueueProvider
- getQueueNames() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
-
Get queue names for alive subscribed subscriber agents.
- getQueueNames(String) - Method in interface org.apache.sling.distribution.journal.queue.PubQueueProvider
-
Get queue names for alive subscribed subscriber agents.
- getQueueState(String, String) - Method in class org.apache.sling.distribution.journal.impl.publisher.MessagingCacheCallback
- getQueueState(String, String) - Method in interface org.apache.sling.distribution.journal.queue.CacheCallback
- getRemovedFailedPackageDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Timer capturing the duration in ms of packages successfully removed automatically from a subscriber supporting error queue.
- getRemovedPackageDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Timer capturing the duration in ms of packages successfully removed from an editable subscriber.
- getRetries() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- getRetries(String) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- getSendStoredStatusDuration() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
-
Timer capturing the duration in ms of sending a stored package status.
- getSize() - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
- getSlingId() - Method in class org.apache.sling.distribution.journal.shared.AgentId
- getState() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
- getState() - Method in class org.apache.sling.distribution.journal.impl.publisher.SimpleDistributionResponse
- getState() - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
- getState(String, String) - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
- getState(DistributionAgent) - Static method in class org.apache.sling.distribution.journal.impl.publisher.AgentState
- getStatus(String, long) - Method in class org.apache.sling.distribution.journal.impl.precondition.PackageStatusWatcher
-
Gets the status that confirms the package at offset pkgOffset
- getStatusTopic() - Method in class org.apache.sling.distribution.journal.shared.Topics
- getSubAgentId() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- getSubAgentName() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- getSubscribedAgentIds() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
-
Return the identifiers of subscriber agents
- getSubscribedAgentIds(String) - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
-
Return the identifiers of subscriber agents subscribed to the given publisher agent.
- getSubscribedAgentIds(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.MessagingCacheCallback
- getSubscribedAgentIds(String) - Method in interface org.apache.sling.distribution.journal.queue.CacheCallback
- getSubscribedAgents(String) - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
-
Return the identifiers of subscriber agents subscribed to the given publisher agent.
- getSubscriberAgentStates(String) - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
-
Return the states for the given subscriber agent.
- getSubscriberCount(String) - Method in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- getSubSlingId() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- getSum() - Method in class org.apache.sling.distribution.journal.bookkeeper.PackageRetries
- getTailOffset() - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
- getTimestamp() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- getTopologyView() - Method in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- getTransientImportErrors() - Method in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- getValue() - Method in class org.apache.sling.distribution.journal.metrics.DefaultTag
- getValue() - Method in interface org.apache.sling.distribution.journal.metrics.Tag
H
- handleDiscovery(MessageInfo, DiscoveryMessage) - Method in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- handleEvent(Event) - Method in class org.apache.sling.distribution.journal.shared.DistributionLogEventListener
- handleInitialOffset(long) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- handleLog(MessageInfo, LogMessage) - Method in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- handleStatus(MessageInfo, PackageStatusMessage) - Method in interface org.apache.sling.distribution.journal.queue.PubQueueProvider
- handleTopologyEvent(TopologyEvent) - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributedEventNotifierManager
- hashCode() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- hashCode() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
- hashCode() - Method in class org.apache.sling.distribution.journal.metrics.DefaultTag
I
- idle() - Method in interface org.apache.sling.distribution.journal.impl.subscriber.IdleCheck
-
Called when processing of a message has finished
- idle() - Method in class org.apache.sling.distribution.journal.impl.subscriber.NoopIdle
- idle() - Method in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReady
-
Called when processing of a message has finished
- IdleCheck - Interface in org.apache.sling.distribution.journal.impl.subscriber
- idleMillies() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- importPackage(PackageMessage, long, long) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
-
We aim at processing the packages exactly once.
- increase(String) - Method in class org.apache.sling.distribution.journal.bookkeeper.PackageRetries
- info(boolean, String, Object...) - Method in class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- info(String, Object...) - Method in class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- INFO - Enum constant in enum org.apache.sling.distribution.journal.shared.DefaultDistributionLog.LogLevel
- Install - Enum constant in enum org.apache.sling.distribution.journal.bookkeeper.PackageHandling
- invalidateCache(PackageMessage, long) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- isAvailable() - Method in class org.apache.sling.distribution.journal.shared.PublisherConfigurationAvailable
- isCleared(long) - Method in class org.apache.sling.distribution.journal.impl.subscriber.CommandPoller
- isEditable() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- isEditable() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- isEmpty() - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
- isLeader() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributedEventNotifierManager
- isReady() - Method in interface org.apache.sling.distribution.journal.impl.subscriber.IdleCheck
- isReady() - Method in class org.apache.sling.distribution.journal.impl.subscriber.NoopIdle
- isReady() - Method in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReady
- isSuccessful() - Method in class org.apache.sling.distribution.journal.impl.publisher.SimpleDistributionResponse
J
- JMXRegistration - Class in org.apache.sling.distribution.journal.shared
- JMXRegistration(Object, String, String) - Constructor for class org.apache.sling.distribution.journal.shared.JMXRegistration
K
- KEY_MESSAGE - Static variable in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- KEY_OFFSET - Static variable in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
L
- load() - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStore
- load(String, Class<T>) - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStore
- load(String, T) - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStore
- loadOffset() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- LocalStore - Class in org.apache.sling.distribution.journal.bookkeeper
- LocalStore(ResourceResolverFactory, String, String) - Constructor for class org.apache.sling.distribution.journal.bookkeeper.LocalStore
- LocalStoreJMX - Class in org.apache.sling.distribution.journal.bookkeeper
- LocalStoreJMX() - Constructor for class org.apache.sling.distribution.journal.bookkeeper.LocalStoreJMX
- LocalStoreJMXMBean - Interface in org.apache.sling.distribution.journal.shared
M
- markStatusSent() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- MAX_RETRIES - Static variable in class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReady
- maxPackageSize() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.PackageFactoryConfiguration
- maxQueueSizeDelay() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.PublisherConfiguration
- maxRetries() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- MessagingCacheCallback - Class in org.apache.sling.distribution.journal.impl.publisher
- MessagingCacheCallback(MessagingProvider, String, PublishMetrics, DiscoveryService, Consumer<ClearCommand>) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.MessagingCacheCallback
N
- name() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.PublisherConfiguration
- name() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- nameOf(String, String) - Static method in class org.apache.sling.distribution.journal.shared.JMXRegistration
- NoopIdle - Class in org.apache.sling.distribution.journal.impl.subscriber
- NoopIdle() - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.NoopIdle
- NoOpImportPostProcessor - Class in org.apache.sling.distribution.journal.shared
- NoOpImportPostProcessor() - Constructor for class org.apache.sling.distribution.journal.shared.NoOpImportPostProcessor
- NoOpImportPreProcessor - Class in org.apache.sling.distribution.journal.shared
-
A no-operation (no-op) implementation of the
ImportPreProcessor
interface. - NoOpImportPreProcessor() - Constructor for class org.apache.sling.distribution.journal.shared.NoOpImportPreProcessor
- NoOpInvalidationProcessor - Class in org.apache.sling.distribution.journal.shared
- NoOpInvalidationProcessor() - Constructor for class org.apache.sling.distribution.journal.shared.NoOpInvalidationProcessor
- notifyDistributed(String, DistributionQueueItem) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
O
- of(String, String) - Static method in interface org.apache.sling.distribution.journal.metrics.Tag
- Off - Enum constant in enum org.apache.sling.distribution.journal.bookkeeper.PackageHandling
- OffsetQueue<T> - Interface in org.apache.sling.distribution.journal.queue
-
A queue of
T
items indexed by offsets. - offsets() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
-
Return a stream of the offsets from all states in the view.
- onError(ProgressTrackerListener.Mode, String, Exception) - Method in class org.apache.sling.distribution.journal.bookkeeper.ErrorListener
- onMessage(ProgressTrackerListener.Mode, String, String) - Method in class org.apache.sling.distribution.journal.bookkeeper.ErrorListener
- org.apache.sling.distribution.journal.bookkeeper - package org.apache.sling.distribution.journal.bookkeeper
- org.apache.sling.distribution.journal.impl.discovery - package org.apache.sling.distribution.journal.impl.discovery
- org.apache.sling.distribution.journal.impl.event - package org.apache.sling.distribution.journal.impl.event
- org.apache.sling.distribution.journal.impl.precondition - package org.apache.sling.distribution.journal.impl.precondition
- org.apache.sling.distribution.journal.impl.publisher - package org.apache.sling.distribution.journal.impl.publisher
- org.apache.sling.distribution.journal.impl.subscriber - package org.apache.sling.distribution.journal.impl.subscriber
- org.apache.sling.distribution.journal.metrics - package org.apache.sling.distribution.journal.metrics
- org.apache.sling.distribution.journal.queue - package org.apache.sling.distribution.journal.queue
- org.apache.sling.distribution.journal.shared - package org.apache.sling.distribution.journal.shared
P
- PACKAGE_ID - Static variable in class org.apache.sling.distribution.journal.impl.event.DistributionEvent
- PACKAGE_MSG - Static variable in class org.apache.sling.distribution.journal.queue.QueueItemFactory
- PACKAGE_TOPIC - Static variable in class org.apache.sling.distribution.journal.shared.Topics
- packageBuilder_target() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.PublisherConfiguration
- packageBuilder_target() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- PackageDistributedNotifier - Class in org.apache.sling.distribution.journal.impl.publisher
- PackageDistributedNotifier(EventAdmin, PubQueueProvider, MessagingProvider, Topics, ResourceResolverFactory, boolean) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
- PackageFactoryConfiguration - Annotation Type in org.apache.sling.distribution.journal.impl.publisher
- packageHandling() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- PackageHandling - Enum in org.apache.sling.distribution.journal.bookkeeper
- PackageMessageFactory - Class in org.apache.sling.distribution.journal.impl.publisher
- PackageMessageFactory() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
- PackageQueuedNotifier - Class in org.apache.sling.distribution.journal.impl.publisher
- PackageQueuedNotifier(EventAdmin) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
- PackageRetries - Class in org.apache.sling.distribution.journal.bookkeeper
-
Holds package retries by agent name
- PackageRetries() - Constructor for class org.apache.sling.distribution.journal.bookkeeper.PackageRetries
- PackageStatus(ValueMap) - Constructor for class org.apache.sling.distribution.journal.bookkeeper.BookKeeper.PackageStatus
- PackageStatusWatcher - Class in org.apache.sling.distribution.journal.impl.precondition
- PackageStatusWatcher(MessagingProvider, Topics) - Constructor for class org.apache.sling.distribution.journal.impl.precondition.PackageStatusWatcher
- packageTopic() - Element in annotation type org.apache.sling.distribution.journal.shared.Topics.TopicsConfiguration
- Precondition - Interface in org.apache.sling.distribution.journal.impl.precondition
-
Extension point for checking if a package can be processed by a subscriber.
- precondition_target() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- Precondition.Decision - Enum in org.apache.sling.distribution.journal.impl.precondition
- PreConditionTimeoutException - Exception Class in org.apache.sling.distribution.journal.impl.subscriber
- PreConditionTimeoutException(String) - Constructor for exception class org.apache.sling.distribution.journal.impl.subscriber.PreConditionTimeoutException
- process(Map<String, Object>) - Method in class org.apache.sling.distribution.journal.shared.NoOpImportPostProcessor
- process(Map<String, Object>) - Method in class org.apache.sling.distribution.journal.shared.NoOpImportPreProcessor
-
Does not perform any pre-import processing on the given properties.
- process(Map<String, Object>) - Method in class org.apache.sling.distribution.journal.shared.NoOpInvalidationProcessor
- PUB_COMPONENT - Static variable in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
- PublisherConfiguration - Annotation Type in org.apache.sling.distribution.journal.impl.publisher
- PublisherConfigurationAvailable - Class in org.apache.sling.distribution.journal.shared
-
This service checks for DistributionPublisher agent configuration availability and registers the marker service
PublisherConfigurationAvailable
when such configuration could be found. - PublisherConfigurationAvailable() - Constructor for class org.apache.sling.distribution.journal.shared.PublisherConfigurationAvailable
- PublishMetrics - Class in org.apache.sling.distribution.journal.impl.publisher
- PublishMetrics(MetricsService, String) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
- PubQueueProvider - Interface in org.apache.sling.distribution.journal.queue
- PubQueueProviderFactory - Interface in org.apache.sling.distribution.journal.queue
- PubQueueProviderPublisher - Class in org.apache.sling.distribution.journal.impl.publisher
-
Normally PubQueueProvider should be created per publish agent.
- PubQueueProviderPublisher(MessagingProvider, DiscoveryService, Topics, MetricsService, PubQueueProviderFactory, BundleContext) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PubQueueProviderPublisher
- putItem(long, T) - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
-
Put an item in the queue at the given offset.
- putItems(OffsetQueue<T>) - Method in interface org.apache.sling.distribution.journal.queue.OffsetQueue
-
Put all the items from the #offsetQueue in this queue.
Q
- QueueCacheSeeder - Class in org.apache.sling.distribution.journal.impl.publisher
- QueueCacheSeeder(MessageSender<PackageMessage>) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.QueueCacheSeeder
- queued(List<FullMessage<PackageMessage>>) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
- queued(List<FullMessage<PackageMessage>>) - Method in interface org.apache.sling.distribution.journal.queue.QueuedCallback
- QueuedCallback - Interface in org.apache.sling.distribution.journal.queue
- queuedTimeout() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.PublisherConfiguration
- QueueItemFactory - Class in org.apache.sling.distribution.journal.queue
- queueSize(Supplier<Integer>) - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
- queueSizeLimit() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.PublisherConfiguration
- QueueState - Class in org.apache.sling.distribution.journal.queue
- QueueState(long, int, int, ClearCallback) - Constructor for class org.apache.sling.distribution.journal.queue.QueueState
R
- RangePoller - Class in org.apache.sling.distribution.journal.impl.publisher
- RangePoller(MessagingProvider, String, long, long, int) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.RangePoller
- RECORD_OFFSET - Static variable in class org.apache.sling.distribution.journal.queue.QueueItemFactory
- RECORD_PARTITION - Static variable in class org.apache.sling.distribution.journal.queue.QueueItemFactory
- RECORD_TIMESTAMP - Static variable in class org.apache.sling.distribution.journal.queue.QueueItemFactory
- RECORD_TOPIC - Static variable in class org.apache.sling.distribution.journal.queue.QueueItemFactory
- refreshState(State) - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyViewManager
- registerWait(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
- removePackage(PackageMessage, long) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- requireNotBlank(String) - Static method in class org.apache.sling.distribution.journal.shared.Strings
- resetStores() - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStoreJMX
- resetStores() - Method in interface org.apache.sling.distribution.journal.shared.LocalStoreJMXMBean
- run() - Method in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- run() - Method in class org.apache.sling.distribution.journal.impl.precondition.StagingPrecondition
- run() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributedEventNotifierManager
S
- sendStoredStatus(int) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- shouldCommitSkipped() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- shouldExtractorOverwriteFolderPrimaryTypes() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- signal() - Method in class org.apache.sling.distribution.journal.shared.Delay
- SimpleDistributionResponse - Class in org.apache.sling.distribution.journal.impl.publisher
- SimpleDistributionResponse(DistributionRequestState, String) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.SimpleDistributionResponse
- SimpleDistributionResponse(DistributionRequestState, String, DistributionResponseInfo) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.SimpleDistributionResponse
- size() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyViewManager
- SKIP - Enum constant in enum org.apache.sling.distribution.journal.impl.precondition.Precondition.Decision
- skipPackage(long) - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- StagingPrecondition - Class in org.apache.sling.distribution.journal.impl.precondition
-
This is a precondition that watches status messages from other instances in order to confirm that a package can be processed.
- StagingPrecondition() - Constructor for class org.apache.sling.distribution.journal.impl.precondition.StagingPrecondition
- startChecks() - Method in class org.apache.sling.distribution.journal.shared.ExponentialBackOff
- startSeeding() - Method in class org.apache.sling.distribution.journal.impl.publisher.QueueCacheSeeder
- State - Class in org.apache.sling.distribution.journal.impl.discovery
- State(String, String, long, long, int, int, boolean) - Constructor for class org.apache.sling.distribution.journal.impl.discovery.State
- status - Variable in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper.PackageStatus
- STATUS_TOPIC - Static variable in class org.apache.sling.distribution.journal.shared.Topics
- statusTopic() - Element in annotation type org.apache.sling.distribution.journal.shared.Topics.TopicsConfiguration
- store(String, Object) - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStore
- store(ResourceResolver, String, Object) - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStore
- store(ResourceResolver, Map<String, Object>) - Method in class org.apache.sling.distribution.journal.bookkeeper.LocalStore
- STORE_TYPE_OFFSETS - Static variable in class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
- STORE_TYPE_STATUS - Static variable in class org.apache.sling.distribution.journal.bookkeeper.BookKeeper
- storeLastDistributedOffset() - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
- Strings - Class in org.apache.sling.distribution.journal.shared
- SUB_COMPONENT - Static variable in class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- subscribedAgentsChanged() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyViewDiff
- SubscriberConfiguration - Annotation Type in org.apache.sling.distribution.journal.impl.subscriber
- subscriberCount(Supplier<Integer>) - Method in class org.apache.sling.distribution.journal.impl.publisher.PublishMetrics
- subscriberIdleCheck() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
- SubscriberIdleCheck - Class in org.apache.sling.distribution.journal.impl.subscriber
- SubscriberIdleCheck(BundleContext, IdleCheck) - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.SubscriberIdleCheck
- SubscriberMetrics - Class in org.apache.sling.distribution.journal.bookkeeper
-
Metrics for DistributionSubscriber most metrics will have two parameters: TAG_SUB_NAME and TAG_EDITABLE
- SubscriberMetrics(MetricsService, String, String, boolean) - Constructor for class org.apache.sling.distribution.journal.bookkeeper.SubscriberMetrics
- SubscriberReady - Class in org.apache.sling.distribution.journal.impl.subscriber
-
A DistributionSubscriber is considered ready when one of the conditions is met: is idle (no further message received) for more than the idleMillis at least once is busy processing the same package for more than MAX_RETRIES times.
- SubscriberReady(String, long, long, AtomicBoolean, Supplier<Long>) - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReady
- SubscriberReadyStore - Class in org.apache.sling.distribution.journal.impl.subscriber
- SubscriberReadyStore() - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.SubscriberReadyStore
T
- Tag - Interface in org.apache.sling.distribution.journal.metrics
- TaggedMetrics - Class in org.apache.sling.distribution.journal.metrics
- timed(Timer, Runnable) - Static method in class org.apache.sling.distribution.journal.shared.Timed
-
Runs provided code updating provided metric with its execution time.
- timed(Timer, Callable<T>) - Static method in class org.apache.sling.distribution.journal.shared.Timed
-
Runs provided code updating provided metric with its execution time.
- Timed - Class in org.apache.sling.distribution.journal.shared
- TOPIC_DISTRIBUTION_LOG - Static variable in class org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- Topics - Class in org.apache.sling.distribution.journal.shared
- Topics() - Constructor for class org.apache.sling.distribution.journal.shared.Topics
- Topics.TopicsConfiguration - Annotation Type in org.apache.sling.distribution.journal.shared
- TopologyChangeHandler - Interface in org.apache.sling.distribution.journal.impl.discovery
- TopologyView - Class in org.apache.sling.distribution.journal.impl.discovery
- TopologyView() - Constructor for class org.apache.sling.distribution.journal.impl.discovery.TopologyView
- TopologyView(Set<State>) - Constructor for class org.apache.sling.distribution.journal.impl.discovery.TopologyView
- TopologyViewDiff - Class in org.apache.sling.distribution.journal.impl.discovery
- TopologyViewDiff(TopologyView, TopologyView) - Constructor for class org.apache.sling.distribution.journal.impl.discovery.TopologyViewDiff
- TopologyViewManager - Class in org.apache.sling.distribution.journal.impl.discovery
- TopologyViewManager(long) - Constructor for class org.apache.sling.distribution.journal.impl.discovery.TopologyViewManager
- toString() - Method in class org.apache.sling.distribution.journal.bookkeeper.BookKeeperConfig
- toString() - Method in class org.apache.sling.distribution.journal.impl.discovery.State
- toString() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyView
U
- unRegisterWait(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
- updated(String, Dictionary<String, ?>) - Method in class org.apache.sling.distribution.journal.shared.PublisherConfigurationAvailable
- updateView() - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyViewManager
-
Update the Topology view
- updateView(long) - Method in class org.apache.sling.distribution.journal.impl.discovery.TopologyViewManager
V
- valueOf(String) - Static method in enum org.apache.sling.distribution.journal.bookkeeper.PackageHandling
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.sling.distribution.journal.impl.precondition.Precondition.Decision
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.sling.distribution.journal.shared.DefaultDistributionLog.LogLevel
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.apache.sling.distribution.journal.bookkeeper.PackageHandling
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.apache.sling.distribution.journal.impl.precondition.Precondition.Decision
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.apache.sling.distribution.journal.shared.DefaultDistributionLog.LogLevel
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- WAIT - Enum constant in enum org.apache.sling.distribution.journal.impl.precondition.Precondition.Decision
- warn(String, Object...) - Method in class org.apache.sling.distribution.journal.shared.DefaultDistributionLog
- WARN - Enum constant in enum org.apache.sling.distribution.journal.shared.DefaultDistributionLog.LogLevel
- webconsole_configurationFactory_nameHint() - Element in annotation type org.apache.sling.distribution.journal.impl.publisher.PublisherConfiguration
- webconsole_configurationFactory_nameHint() - Element in annotation type org.apache.sling.distribution.journal.impl.subscriber.SubscriberConfiguration
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form