Class RangePoller
java.lang.Object
org.apache.sling.distribution.journal.impl.publisher.RangePoller
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionRangePoller
(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, long minOffset, long maxOffsetExclusive, int seedDelaySeconds) -
Method Summary
Modifier and TypeMethodDescriptionList
<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>>
-
Field Details
-
DEFAULT_SEED_DELAY_SECONDS
public static final int DEFAULT_SEED_DELAY_SECONDS- See Also:
-
-
Constructor Details
-
RangePoller
public RangePoller(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, long minOffset, long maxOffsetExclusive, int seedDelaySeconds)
-
-
Method Details
-
fetchRange
public List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>> fetchRange() throws InterruptedException- Throws:
InterruptedException
-