public class PackageStatusWatcher extends Object implements Closeable
Constructor and Description |
---|
PackageStatusWatcher(org.apache.sling.distribution.journal.MessagingProvider messagingProvider,
Topics topics,
String subAgentName) |
Modifier and Type | Method and Description |
---|---|
void |
clear(long pkgOffset)
Clear all offsets in the cache smaller to the given pkgOffset.
|
void |
close() |
org.apache.sling.distribution.journal.messages.Messages.PackageStatusMessage.Status |
getStatus(long pkgOffset)
Gets the status that confirms the package at offset pkgOffset
|
Long |
getStatusOffset(long pkgOffset)
Gets the status offset that confirms the packages at offset pkgOffset
|
void |
handle(org.apache.sling.distribution.journal.MessageInfo info,
org.apache.sling.distribution.journal.messages.Messages.PackageStatusMessage msg) |
public org.apache.sling.distribution.journal.messages.Messages.PackageStatusMessage.Status getStatus(long pkgOffset)
pkgOffset
- the offset of the packagepublic Long getStatusOffset(long pkgOffset)
pkgOffset
- the offset of the packagepublic void clear(long pkgOffset)
pkgOffset
- public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public void handle(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.Messages.PackageStatusMessage msg)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.