Skip navigation links
A B C D E F G H I J L O P Q R S T U V W 

A

activate(BundleContext) - Method in class org.apache.sling.distribution.journal.impl.publisher.DiscoveryService
 
activate(PublisherConfiguration, BundleContext) - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
 
activate() - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
 
activate() - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
 
activate() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCacheService
 
activate() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueProviderImpl
 
activate(BundleContext) - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
 
activate(BundleContext) - Method in class org.apache.sling.distribution.journal.impl.shared.JournalAvailableChecker
 
activate(Topics.TopicsConfiguration) - Method in class org.apache.sling.distribution.journal.impl.shared.Topics
 
activate(SubscriberConfiguration, BundleContext, Map<String, Object>) - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
 
activate(StagingPrecondition.Configuration) - Method in class org.apache.sling.distribution.journal.impl.subscriber.StagingPrecondition
 
add(DistributionQueueItem) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
add(DistributionQueueItem) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
add(DistributionQueueItem) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
AgentId - Class in org.apache.sling.distribution.journal.impl.publisher
 
AgentId(String) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.AgentId
 
AgentId(String, String) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.AgentId
 
AgentState - Class in org.apache.sling.distribution.journal.impl.shared
 
AgentState() - Constructor for class org.apache.sling.distribution.journal.impl.shared.AgentState
 

B

BASE_COMPONENT - Static variable in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
 

C

canProcess(long, int) - Method in class org.apache.sling.distribution.journal.impl.subscriber.DefaultPrecondition
 
canProcess(long, int) - Method in interface org.apache.sling.distribution.journal.impl.subscriber.Precondition
Checks if a package can be processed
canProcess(long, int) - Method in class org.apache.sling.distribution.journal.impl.subscriber.StagingPrecondition
 
cardinal - Variable in enum org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog.LogLevel
 
changed(TopologyView, TopologyView) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
 
changed(TopologyView, TopologyView) - Method in interface org.apache.sling.distribution.journal.impl.publisher.TopologyChangeHandler
Invoked by the framework when the TopologyView has changed.
cleanup() - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageRepo
The cleanup algorithm is based on the head and tail offsets fetched from the package topic.
clear(long) - Method in interface org.apache.sling.distribution.journal.impl.queue.impl.ClearCallback
 
clear(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PackageRetries
 
clear(int) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
clear(int) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
clear(int) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
clear(long) - Method in class org.apache.sling.distribution.journal.impl.subscriber.PackageStatusWatcher
Clear all offsets in the cache smaller to the given pkgOffset.
ClearCallback - Interface in org.apache.sling.distribution.journal.impl.queue.impl
 
close() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCache
 
close() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService.GaugeService
 
close() - Method in class org.apache.sling.distribution.journal.impl.shared.JMXRegistration
 
close() - Method in class org.apache.sling.distribution.journal.impl.subscriber.PackageStatusWatcher
 
COMMAND_TOPIC - Static variable in class org.apache.sling.distribution.journal.impl.shared.Topics
 
create(DistributionPackageBuilder, ResourceResolver, String, DistributionRequest) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
 
create(DistributionQueueItem) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.QueueEntryFactory
 
createGauge(String, String, Supplier<T>) - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
 
createTest(DistributionPackageBuilder, ResourceResolver, String) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
 

D

deactivate() - Method in class org.apache.sling.distribution.journal.impl.publisher.DiscoveryService
 
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.PackageQueuedNotifier
 
deactivate() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCacheService
 
deactivate() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueProviderImpl
 
deactivate() - Method in class org.apache.sling.distribution.journal.impl.shared.JournalAvailableChecker
 
deactivate() - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
 
deactivate() - Method in class org.apache.sling.distribution.journal.impl.subscriber.StagingPrecondition
 
debug(String, Object...) - Method in class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
DefaultDistributionLog - Class in org.apache.sling.distribution.journal.impl.shared
Default implementation of a DistributionLog
DefaultDistributionLog(String, Class<?>, DefaultDistributionLog.LogLevel) - Constructor for class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
DefaultDistributionLog.LogLevel - Enum in org.apache.sling.distribution.journal.impl.shared
Log level
DefaultPrecondition - Class in org.apache.sling.distribution.journal.impl.subscriber
 
DefaultPrecondition() - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.DefaultPrecondition
 
DISCOVERY_TOPIC - Static variable in class org.apache.sling.distribution.journal.impl.shared.Topics
 
DiscoveryService - Class in org.apache.sling.distribution.journal.impl.publisher
Listens for discovery messages and tracks presence of Subscribers as well as the last processed offset of each Subscriber This component uses lazy starting so it is only started when there is at least one Agent that requires it.
DiscoveryService() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.DiscoveryService
 
DiscoveryService(MessagingProvider, TopologyChangeHandler, Topics) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.DiscoveryService
 
DistPublisherJMXMBean - Interface in org.apache.sling.distribution.journal.impl.publisher
 
DistributionEvent - Class in org.apache.sling.distribution.journal.impl.event
 
DistributionEvent() - Constructor for class org.apache.sling.distribution.journal.impl.event.DistributionEvent
 
DistributionMetricsService - Class in org.apache.sling.distribution.journal.impl.shared
 
DistributionMetricsService() - Constructor for class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
 
DistributionMetricsService.GaugeService<T> - Class in org.apache.sling.distribution.journal.impl.shared
 
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() - 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.impl.shared.JMXRegistration
 

E

entryId(DistributionQueueItem) - Static method in class org.apache.sling.distribution.journal.impl.queue.impl.EntryUtil
 
entryOffset(String) - Static method in class org.apache.sling.distribution.journal.impl.queue.impl.EntryUtil
 
EntryUtil - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
EntryUtil() - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.EntryUtil
 
equals(Object) - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
equals(Object) - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
 
error(String, Object...) - Method in class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
EVENT_TOPIC - Static variable in class org.apache.sling.distribution.journal.impl.shared.Topics
 
eventImporterImported(Messages.PackageMessage, String) - Static method in class org.apache.sling.distribution.journal.impl.event.DistributionEvent
 
eventPackageCreated(Messages.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(Messages.PackageMessage, String) - Static method in class org.apache.sling.distribution.journal.impl.event.DistributionEvent
 
execute(ResourceResolver, DistributionRequest) - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
 
execute(ResourceResolver, DistributionRequest) - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
 

F

fetchRange() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.RangePoller
 
fromPackage(FullMessage<Messages.PackageMessage>) - Static method in class org.apache.sling.distribution.journal.impl.queue.QueueItemFactory
 
fromPackage(MessageInfo, Messages.PackageMessage, boolean) - Static method in class org.apache.sling.distribution.journal.impl.queue.QueueItemFactory
 

G

get(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PackageRetries
 
getAcceptedRequests() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Meter of requests returning an DistributionRequestState.ACCEPTED state.
getAgentId() - Method in class org.apache.sling.distribution.journal.impl.publisher.AgentId
 
getAgentName() - Method in class org.apache.sling.distribution.journal.impl.publisher.AgentId
 
getBuildPackageDuration() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Timer capturing the duration in ms of building a content package
getCleanupPackageDuration() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Timer of the Package Cleanup Task execution duration.
getCleanupPackageRemovedCount() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Counter of package removed during the Package Cleanup Task.
getCommandTopic() - Method in class org.apache.sling.distribution.journal.impl.shared.Topics
 
getCurrentView() - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyViewManager
 
getDiscoveryTopic() - Method in class org.apache.sling.distribution.journal.impl.shared.Topics
 
getDroppedRequests() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Meter of requests returning an DistributionRequestState.DROPPED state.
getEnqueuePackageDuration() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Timer capturing the duration in ms of adding a package to the queue
getEntries(int, int) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
getEntries(int, int) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
getEntries(int, int) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
getEntry(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
getEntry(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
getEntry(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
getErrorQueue(String, String, String, String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueProviderImpl
 
getErrorQueue(String, String, String, String) - Method in interface org.apache.sling.distribution.journal.impl.queue.PubQueueProvider
 
getEventTopic() - Method in class org.apache.sling.distribution.journal.impl.shared.Topics
 
getExportedPackageSize() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Histogram of the exported content package size in Bytes.
getFailedPackageImports() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Meter of failures to import packages.
getHead() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
getHead() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
getHead() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
getHeadItem() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
getHeadItem() - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
Return the item with the smallest offset in the queue.
getHeadItems(int, int) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
getHeadItems(int, int) - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
Return #limit items after skipping #skip items from the queue.
getHeadOffset() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
getHeadOffset() - Method in interface org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImplMBean
 
getHeadOffset() - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
 
getImportedPackageDuration() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Timer capturing the duration in ms of successful packages import operations.
getImportedPackageSize() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Histogram of the imported content package size in Byte.
getItem(long) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
getItem(long) - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
Return the item at the given #offset.
getItemsBufferSize() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Counter of the package buffer size on the subscriber.
getLines() - Method in class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
getLog() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
 
getLog() - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
 
getMaxRetries() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
getMessage() - Method in class org.apache.sling.distribution.journal.impl.shared.SimpleDistributionResponse
 
getMinOffset() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCache
 
getMinOffsetByPubAgentName() - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
Return the map of min offset per publisher agent
getMinOffsetQueue(long) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
getMinOffsetQueue(long) - Method in interface org.apache.sling.distribution.journal.impl.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.impl.queue.impl.PubErrQueue
 
getName() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
getName() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
getName() - Method in class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
getOffset() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
getOffsetPerSubscriber() - Method in interface org.apache.sling.distribution.journal.impl.publisher.DistPublisherJMXMBean
 
getOffsetQueue(String, long) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCache
 
getOffsetQueue(String, long) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCacheService
 
getPackageDistributedDuration() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Timer capturing the duration in ms of distributing a distribution package.
getPackageTopic() - Method in class org.apache.sling.distribution.journal.impl.shared.Topics
 
getProcessedOffsets() - Method in class org.apache.sling.distribution.journal.impl.publisher.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.impl.shared.DistributionMetricsService
Timer capturing the duration in ms of processing a queue item.
getPubAgentName() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
getQueue(String) - Method in interface org.apache.sling.distribution.journal.impl.publisher.DistPublisherJMXMBean
 
getQueue(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
 
getQueue(String, String, String, String, long, int, boolean) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueProviderImpl
 
getQueue(String, String, String, String, long, int, boolean) - Method in interface org.apache.sling.distribution.journal.impl.queue.PubQueueProvider
 
getQueue(String) - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
 
getQueueCacheFetchCount() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Counter of fetch operations to feed the queue cache.
getQueueNames() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
Get queue names for alive subscribed subscriber agents.
getQueueNames() - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
 
getRemovedFailedPackageDuration() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
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.impl.shared.DistributionMetricsService
Timer capturing the duration in ms of packages successfully removed from an editable subscriber.
getRetries() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
getSendStoredStatusDuration() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Timer capturing the duration in ms of sending a stored package status.
getSize() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
getSize() - Method in interface org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImplMBean
 
getSize() - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
 
getSlingId() - Method in class org.apache.sling.distribution.journal.impl.publisher.AgentId
 
getState() - Method in class org.apache.sling.distribution.journal.impl.publisher.DistributionPublisher
 
getState(String, String) - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
 
getState(DistributionAgent) - Static method in class org.apache.sling.distribution.journal.impl.shared.AgentState
 
getState() - Method in class org.apache.sling.distribution.journal.impl.shared.SimpleDistributionResponse
 
getState() - Method in class org.apache.sling.distribution.journal.impl.subscriber.DistributionSubscriber
 
getStatus() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
getStatus() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
getStatus() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
getStatus(long) - Method in class org.apache.sling.distribution.journal.impl.subscriber.PackageStatusWatcher
Gets the status that confirms the package at offset pkgOffset
getStatusOffset(long) - Method in class org.apache.sling.distribution.journal.impl.subscriber.PackageStatusWatcher
Gets the status offset that confirms the packages at offset pkgOffset
getStatusTopic() - Method in class org.apache.sling.distribution.journal.impl.shared.Topics
 
getSubAgentId() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
getSubscribedAgentIds() - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
Return the identifiers of subscriber agents
getSubscribedAgentIds(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
Return the identifiers of subscriber agents subscribed to the given publisher agent.
getSubscribedAgents(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
Return the identifiers of subscriber agents subscribed to the given publisher agent.
getSubscriberAgentStates(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
Return the states for the given subscriber agent.
getSum() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PackageRetries
 
getTailOffset() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
getTailOffset() - Method in interface org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImplMBean
 
getTailOffset() - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
 
getTimestamp() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
getTopologyView() - Method in class org.apache.sling.distribution.journal.impl.publisher.DiscoveryService
 
getType() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
getType() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
getType() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
getValue() - Method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService.GaugeService
 

H

handle(MessageInfo, Messages.PackageStatusMessage) - Method in class org.apache.sling.distribution.journal.impl.subscriber.PackageStatusWatcher
 
handleEvent(Event) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
 
handleStatus(MessageInfo, Messages.PackageStatusMessage) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueProviderImpl
 
hasCapability(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
hasCapability(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
hasCapability(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
hashCode() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
hashCode() - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
 

I

increase(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PackageRetries
 
info(String, Object...) - Method in class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
info(boolean, String, Object...) - Method in class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
isAvailable() - Method in class org.apache.sling.distribution.journal.impl.shared.JournalAvailableChecker
 
isEditable() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
isEmpty() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
isEmpty() - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
 
isSuccessful() - Method in class org.apache.sling.distribution.journal.impl.shared.SimpleDistributionResponse
 

J

JMXRegistration - Class in org.apache.sling.distribution.journal.impl.shared
 
JMXRegistration(Object, String, String) - Constructor for class org.apache.sling.distribution.journal.impl.shared.JMXRegistration
 
JournalAvailableChecker - Class in org.apache.sling.distribution.journal.impl.shared
 
JournalAvailableChecker() - Constructor for class org.apache.sling.distribution.journal.impl.shared.JournalAvailableChecker
 

L

load(String, T) - Method in class org.apache.sling.distribution.journal.impl.subscriber.LocalStore
 
load() - Method in class org.apache.sling.distribution.journal.impl.subscriber.LocalStore
 
LocalStore - Class in org.apache.sling.distribution.journal.impl.subscriber
 
LocalStore(ResourceResolverFactory, String, String) - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.LocalStore
 

O

OffsetQueue<T> - Interface in org.apache.sling.distribution.journal.impl.queue
A queue of T items indexed by offsets.
OffsetQueueImpl<T> - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
OffsetQueueImpl() - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
OffsetQueueImplMBean - Interface in org.apache.sling.distribution.journal.impl.queue.impl
 
org.apache.sling.distribution.journal.impl.event - package org.apache.sling.distribution.journal.impl.event
 
org.apache.sling.distribution.journal.impl.publisher - package org.apache.sling.distribution.journal.impl.publisher
 
org.apache.sling.distribution.journal.impl.queue - package org.apache.sling.distribution.journal.impl.queue
 
org.apache.sling.distribution.journal.impl.queue.impl - package org.apache.sling.distribution.journal.impl.queue.impl
 
org.apache.sling.distribution.journal.impl.shared - package org.apache.sling.distribution.journal.impl.shared
 
org.apache.sling.distribution.journal.impl.subscriber - package org.apache.sling.distribution.journal.impl.subscriber
 

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.impl.queue.QueueItemFactory
 
PACKAGE_TOPIC - Static variable in class org.apache.sling.distribution.journal.impl.shared.Topics
 
PackageCleanupTask - Class in org.apache.sling.distribution.journal.impl.publisher
The cleanup task fetches the head offset (the smallest) and the tail offset (the current biggest) on the package topic.
PackageCleanupTask() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageCleanupTask
 
PackageDistributedNotifier - Class in org.apache.sling.distribution.journal.impl.publisher
 
PackageDistributedNotifier() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
 
PackageMessageFactory - Class in org.apache.sling.distribution.journal.impl.publisher
 
PackageMessageFactory() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
 
PackageMessageFactory(String) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageMessageFactory
 
PackageQueuedNotifier - Class in org.apache.sling.distribution.journal.impl.publisher
 
PackageQueuedNotifier() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
 
PackageRepo - Class in org.apache.sling.distribution.journal.impl.publisher
Manages the binary content of DistributionPackages.
PackageRepo() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.PackageRepo
 
PackageRetries - Class in org.apache.sling.distribution.journal.impl.queue.impl
Holds package retries by agent name
PackageRetries() - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PackageRetries
 
PackageStatusWatcher - Class in org.apache.sling.distribution.journal.impl.subscriber
 
PackageStatusWatcher(MessagingProvider, Topics, String) - Constructor for class org.apache.sling.distribution.journal.impl.subscriber.PackageStatusWatcher
 
Precondition - Interface in org.apache.sling.distribution.journal.impl.subscriber
Extension point for checking if a package can be processed by a subscriber.
processOffset(String, DistributionQueueItem) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageDistributedNotifier
 
PubErrQueue - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
PubErrQueue(String, OffsetQueue<DistributionQueueItem>, OffsetQueue<Long>) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
PublisherConfiguration - Annotation Type in org.apache.sling.distribution.journal.impl.publisher
 
PubQueue - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
PubQueue(String, OffsetQueue<DistributionQueueItem>, int, ClearCallback) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
PubQueueCache - Class in org.apache.sling.distribution.journal.impl.queue.impl
Cache the distribution packages fetched from the package topic.
PubQueueCache(MessagingProvider, EventAdmin, DistributionMetricsService, String) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCache
 
PubQueueCacheService - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
PubQueueCacheService() - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCacheService
 
PubQueueCacheService(MessagingProvider, Topics, EventAdmin) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCacheService
 
PubQueueProvider - Interface in org.apache.sling.distribution.journal.impl.queue
 
PubQueueProviderImpl - Class in org.apache.sling.distribution.journal.impl.queue.impl
As reading all messages is an expensive operation this component is activated lazily only when requested by the Publisher.
PubQueueProviderImpl() - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueProviderImpl
 
PubQueueProviderImpl(PubQueueCacheService, MessagingProvider, Topics) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueProviderImpl
 
putItem(long, T) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
putItem(long, T) - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
Put an item in the queue at the given offset.
putItems(OffsetQueue<T>) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.OffsetQueueImpl
 
putItems(OffsetQueue<T>) - Method in interface org.apache.sling.distribution.journal.impl.queue.OffsetQueue
Put all the items from the #offsetQueue in this queue.

Q

QueueEntryFactory - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
QueueEntryFactory(String, Function<DistributionQueueItem, Integer>) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.QueueEntryFactory
 
QueueItemFactory - Class in org.apache.sling.distribution.journal.impl.queue
 
QueueItemFactory() - Constructor for class org.apache.sling.distribution.journal.impl.queue.QueueItemFactory
 

R

RangePoller - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
RangePoller(MessagingProvider, String, long, long) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.RangePoller
 
RECORD_OFFSET - Static variable in class org.apache.sling.distribution.journal.impl.queue.QueueItemFactory
 
RECORD_PARTITION - Static variable in class org.apache.sling.distribution.journal.impl.queue.QueueItemFactory
 
RECORD_TIMESTAMP - Static variable in class org.apache.sling.distribution.journal.impl.queue.QueueItemFactory
 
RECORD_TOPIC - Static variable in class org.apache.sling.distribution.journal.impl.queue.QueueItemFactory
 
refreshState(State) - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyViewManager
 
registerWait(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
 
remove(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
remove(Set<String>) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubErrQueue
 
remove(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
remove(Set<String>) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueue
 
remove(String) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
remove(Set<String>) - Method in class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
run() - Method in class org.apache.sling.distribution.journal.impl.publisher.DiscoveryService
 
run() - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageCleanupTask
 
run() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCacheService
 
run() - Method in class org.apache.sling.distribution.journal.impl.shared.JournalAvailableChecker
 

S

SimpleDistributionResponse - Class in org.apache.sling.distribution.journal.impl.shared
 
SimpleDistributionResponse(DistributionRequestState, String) - Constructor for class org.apache.sling.distribution.journal.impl.shared.SimpleDistributionResponse
 
size() - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyViewManager
 
size() - Method in class org.apache.sling.distribution.journal.impl.queue.impl.PubQueueCache
 
StagingPrecondition - Class in org.apache.sling.distribution.journal.impl.subscriber
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.subscriber.StagingPrecondition
 
StagingPrecondition.Configuration - Annotation Type in org.apache.sling.distribution.journal.impl.subscriber
 
State - Class in org.apache.sling.distribution.journal.impl.publisher
 
State(String, String, long, long, int, int, boolean) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.State
 
STATUS_TOPIC - Static variable in class org.apache.sling.distribution.journal.impl.shared.Topics
 
store(ResourceResolver, DistributionPackage) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageRepo
 
store(ResourceResolver, String, Object) - Method in class org.apache.sling.distribution.journal.impl.subscriber.LocalStore
 
store(ResourceResolver, Map<String, Object>) - Method in class org.apache.sling.distribution.journal.impl.subscriber.LocalStore
 
SUB_COMPONENT - Static variable in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
 
SubQueue - Class in org.apache.sling.distribution.journal.impl.queue.impl
 
SubQueue(String, DistributionQueueItem, PackageRetries) - Constructor for class org.apache.sling.distribution.journal.impl.queue.impl.SubQueue
 
SubscriberConfiguration - Annotation Type in org.apache.sling.distribution.journal.impl.subscriber
 

T

timed(Timer, Runnable) - Static method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Runs provided code updating provided metric with its execution time.
timed(Timer, Callable<T>) - Static method in class org.apache.sling.distribution.journal.impl.shared.DistributionMetricsService
Runs provided code updating provided metric with its execution time.
Topics - Class in org.apache.sling.distribution.journal.impl.shared
 
Topics() - Constructor for class org.apache.sling.distribution.journal.impl.shared.Topics
 
Topics.TopicsConfiguration - Annotation Type in org.apache.sling.distribution.journal.impl.shared
 
TopologyChangeHandler - Interface in org.apache.sling.distribution.journal.impl.publisher
 
TopologyView - Class in org.apache.sling.distribution.journal.impl.publisher
 
TopologyView() - Constructor for class org.apache.sling.distribution.journal.impl.publisher.TopologyView
 
TopologyView(Set<State>) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.TopologyView
 
TopologyViewDiff - Class in org.apache.sling.distribution.journal.impl.publisher
 
TopologyViewDiff(TopologyView, TopologyView) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.TopologyViewDiff
 
TopologyViewManager - Class in org.apache.sling.distribution.journal.impl.publisher
 
TopologyViewManager(long) - Constructor for class org.apache.sling.distribution.journal.impl.publisher.TopologyViewManager
 
toString() - Method in class org.apache.sling.distribution.journal.impl.publisher.State
 
toString() - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyView
 

U

unRegisterWait(String) - Method in class org.apache.sling.distribution.journal.impl.publisher.PackageQueuedNotifier
 
updateView() - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyViewManager
Update the Topology view
updateView(long) - Method in class org.apache.sling.distribution.journal.impl.publisher.TopologyViewManager
 

V

valueOf(String) - Static method in enum org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog.LogLevel
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog.LogLevel
Returns an array containing the constants of this enum type, in the order they are declared.

W

warn(String, Object...) - Method in class org.apache.sling.distribution.journal.impl.shared.DefaultDistributionLog
 
A B C D E F G H I J L O P Q R S T U V W 
Skip navigation links

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.