public interface MessagingProvider
Modifier and Type | Method and Description |
---|---|
void |
assertTopic(String topic) |
String |
assignTo(long offset) |
<T> Closeable |
createJsonPoller(String topicName,
Reset reset,
MessageHandler<T> handler,
Class<T> type) |
<T> JsonMessageSender<T> |
createJsonSender() |
<T> Closeable |
createPoller(String topicName,
Reset reset,
HandlerAdapter<?>... adapters) |
Closeable |
createPoller(String topicName,
Reset reset,
String assign,
HandlerAdapter<?>... adapters) |
<T extends com.google.protobuf.GeneratedMessage> |
createSender() |
long |
retrieveOffset(String topicName,
Reset reset) |
<T extends com.google.protobuf.GeneratedMessage> MessageSender<T> createSender()
<T> Closeable createPoller(String topicName, Reset reset, HandlerAdapter<?>... adapters)
Closeable createPoller(String topicName, Reset reset, String assign, HandlerAdapter<?>... adapters)
<T> JsonMessageSender<T> createJsonSender()
<T> Closeable createJsonPoller(String topicName, Reset reset, MessageHandler<T> handler, Class<T> type)
void assertTopic(String topic) throws MessagingException
MessagingException
String assignTo(long offset)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.