Package | Description |
---|---|
org.apache.sling.distribution.journal |
Modifier and Type | Method and Description |
---|---|
static <T> HandlerAdapter<T> |
HandlerAdapter.create(Class<T> type,
MessageHandler<T> handler) |
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.