@ParametersAreNonnullByDefault public class RangePoller extends Object
Constructor and Description |
---|
RangePoller(org.apache.sling.distribution.journal.MessagingProvider messagingProvider,
String packageTopic,
long minOffset,
long maxOffset) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.Messages.PackageMessage>> |
fetchRange() |
public RangePoller(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, long minOffset, long maxOffset)
public List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.Messages.PackageMessage>> fetchRange() throws InterruptedException
InterruptedException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.