Package | Description |
---|---|
org.apache.sling.distribution.journal |
Modifier and Type | Method and Description |
---|---|
static Reset |
Reset.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Reset[] |
Reset.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
String |
MessagingProvider.assignTo(Reset reset,
long relativeOffset)
Get assign String to feed into createPoller based on either earliest or latest and a relative offset.
|
default Closeable |
MessagingProvider.createPoller(String topicName,
Reset reset,
HandlerAdapter<?>... adapters) |
Closeable |
MessagingProvider.createPoller(String topicName,
Reset reset,
String assign,
HandlerAdapter<?>... adapters)
Create a poller which listens to a topic and starts at a given reset or assigned offset.
|
long |
MessagingProvider.retrieveOffset(String topicName,
Reset reset)
Retrieve earliest or latest offset for a topic
|
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.