Uses of Interface
org.apache.pulsar.client.api.Reader
Packages that use Reader
-
Uses of Reader in org.apache.pulsar.client.api
Methods in org.apache.pulsar.client.api that return ReaderModifier and TypeMethodDescriptionReaderBuilder.create()
Finalize the creation of theReader
instance.Methods in org.apache.pulsar.client.api that return types with arguments of type ReaderModifier and TypeMethodDescriptionReaderBuilder.createAsync()
Finalize the creation of theReader
instance in asynchronous mode.Methods in org.apache.pulsar.client.api with parameters of type ReaderModifier and TypeMethodDescriptionReaderInterceptor.beforeRead
(Reader<T> reader, Message<T> message) This is called just before the message is returned byreadNext()
,ReaderListener.received(Reader, Message)
or theCompletableFuture
returned byreadNextAsync()
completes.default void
ReaderListener.reachedEndOfTopic
(Reader<T> reader) Get the notification when a topic is terminated.void
This method is called whenever a new message is received.