Class BufferingPullSubscriber (1.13.6)

public class BufferingPullSubscriber implements PullSubscriber<SequencedMessage>

Inheritance

java.lang.Object > BufferingPullSubscriber

Implements

com.google.cloud.pubsublite.internal.PullSubscriber<com.google.cloud.pubsublite.proto.SequencedMessage>

Constructors

BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings)

public BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings)
Parameters
Name Description
factory SubscriberFactory
settings FlowControlSettings

Methods

close()

public void close()

nextOffset()

public synchronized Optional<Offset> nextOffset()
Returns
Type Description
Optional<Offset>

pull()

public synchronized List<SequencedMessage> pull()
Returns
Type Description
List<SequencedMessage>
Exceptions
Type Description
CheckedApiException