@ParametersAreNonnullByDefault public class PubQueueProviderImpl extends Object implements PubQueueProvider, Runnable
Constructor and Description |
---|
PubQueueProviderImpl(org.osgi.service.event.EventAdmin eventAdmin,
QueueErrors queueErrors,
CacheCallback callback,
org.osgi.framework.BundleContext context) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> |
getOffsetQueue(String pubAgentName,
long minOffset) |
org.apache.sling.distribution.queue.spi.DistributionQueue |
getQueue(String pubAgentName,
String queueName) |
PackageQueuedNotifier |
getQueuedNotifier() |
Set<String> |
getQueueNames(String pubAgentName)
Get queue names for alive subscribed subscriber agents.
|
void |
handleStatus(org.apache.sling.distribution.journal.MessageInfo info,
org.apache.sling.distribution.journal.messages.PackageStatusMessage message) |
void |
run() |
public PubQueueProviderImpl(org.osgi.service.event.EventAdmin eventAdmin, QueueErrors queueErrors, CacheCallback callback, org.osgi.framework.BundleContext context)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
@Nonnull public Set<String> getQueueNames(String pubAgentName)
PubQueueProvider
getQueueNames
in interface PubQueueProvider
@Nonnull public PackageQueuedNotifier getQueuedNotifier()
getQueuedNotifier
in interface PubQueueProvider
@Nullable public org.apache.sling.distribution.queue.spi.DistributionQueue getQueue(String pubAgentName, String queueName)
getQueue
in interface PubQueueProvider
@Nonnull public OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> getOffsetQueue(String pubAgentName, long minOffset)
getOffsetQueue
in interface PubQueueProvider
public void handleStatus(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.PackageStatusMessage message)
handleStatus
in interface PubQueueProvider
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.