public class BookKeeper extends Object implements Closeable
Modifier and Type | Class and Description |
---|---|
static class |
BookKeeper.PackageStatus |
Modifier and Type | Field and Description |
---|---|
static int |
COMMIT_AFTER_NUM_SKIPPED |
static String |
KEY_OFFSET |
static String |
STORE_TYPE_STATUS |
Constructor and Description |
---|
BookKeeper(org.apache.sling.api.resource.ResourceResolverFactory resolverFactory,
DistributionMetricsService distributionMetricsService,
org.apache.sling.distribution.journal.bookkeeper.PackageHandler packageHandler,
org.osgi.service.event.EventAdmin eventAdmin,
Consumer<org.apache.sling.distribution.journal.messages.PackageStatusMessage> sender,
Consumer<org.apache.sling.distribution.journal.messages.LogMessage> logSender,
BookKeeperConfig config) |
BookKeeper(org.apache.sling.api.resource.ResourceResolverFactory resolverFactory,
DistributionMetricsService distributionMetricsService,
org.apache.sling.distribution.journal.bookkeeper.PackageHandler packageHandler,
org.osgi.service.event.EventAdmin eventAdmin,
Consumer<org.apache.sling.distribution.journal.messages.PackageStatusMessage> sender,
Consumer<org.apache.sling.distribution.journal.messages.LogMessage> logSender,
BookKeeperConfig config,
org.apache.sling.distribution.ImportPostProcessor importPostProcessor) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
PackageRetries |
getPackageRetries() |
int |
getRetries(String pubAgentName) |
void |
importPackage(org.apache.sling.distribution.journal.messages.PackageMessage pkgMsg,
long offset,
long createdTime)
We aim at processing the packages exactly once.
|
long |
loadOffset() |
void |
markStatusSent() |
void |
removePackage(org.apache.sling.distribution.journal.messages.PackageMessage pkgMsg,
long offset) |
boolean |
sendStoredStatus(int retry) |
boolean |
shouldCommitSkipped() |
void |
skipPackage(long offset) |
public static final String STORE_TYPE_STATUS
public static final String KEY_OFFSET
public static final int COMMIT_AFTER_NUM_SKIPPED
public BookKeeper(org.apache.sling.api.resource.ResourceResolverFactory resolverFactory, DistributionMetricsService distributionMetricsService, org.apache.sling.distribution.journal.bookkeeper.PackageHandler packageHandler, org.osgi.service.event.EventAdmin eventAdmin, Consumer<org.apache.sling.distribution.journal.messages.PackageStatusMessage> sender, Consumer<org.apache.sling.distribution.journal.messages.LogMessage> logSender, BookKeeperConfig config)
public BookKeeper(org.apache.sling.api.resource.ResourceResolverFactory resolverFactory, DistributionMetricsService distributionMetricsService, org.apache.sling.distribution.journal.bookkeeper.PackageHandler packageHandler, org.osgi.service.event.EventAdmin eventAdmin, Consumer<org.apache.sling.distribution.journal.messages.PackageStatusMessage> sender, Consumer<org.apache.sling.distribution.journal.messages.LogMessage> logSender, BookKeeperConfig config, org.apache.sling.distribution.ImportPostProcessor importPostProcessor)
public void importPackage(org.apache.sling.distribution.journal.messages.PackageMessage pkgMsg, long offset, long createdTime) throws org.apache.sling.distribution.common.DistributionException
org.apache.sling.distribution.common.DistributionException
public void removePackage(org.apache.sling.distribution.journal.messages.PackageMessage pkgMsg, long offset) throws org.apache.sling.api.resource.LoginException, org.apache.sling.api.resource.PersistenceException
org.apache.sling.api.resource.LoginException
org.apache.sling.api.resource.PersistenceException
public void skipPackage(long offset) throws org.apache.sling.api.resource.LoginException, org.apache.sling.api.resource.PersistenceException
org.apache.sling.api.resource.LoginException
org.apache.sling.api.resource.PersistenceException
public boolean shouldCommitSkipped()
public boolean sendStoredStatus(int retry)
true
if the status has been sent ;
false
otherwise.public void markStatusSent()
public long loadOffset()
public int getRetries(String pubAgentName)
public PackageRetries getPackageRetries()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.