Interface BlockingPullSubscriber (1.7.1)
Stay organized with collections Save and categorize content based on your preferences.

public interface BlockingPullSubscriber extends AutoCloseable

Implements

AutoCloseable

Methods

close()

public abstract void close()

messageIfAvailable()

public abstract Optional<SequencedMessage> messageIfAvailable()

Pull messages if there is any ready to deliver. Any message will only be delivered to one call if there are multiple concurrent calls.

Returns

Type	Description
Optional<SequencedMessage>

Exceptions

Type	Description
CheckedApiException	if there is underlying permanent error.

onData()

public abstract ApiFuture<Void> onData()

Returns a ApiFuture that will be completed when there are messages available. Unfinished existing ApiFuture returned by onData() will be abandoned and superseded by new onData() call.

CheckedApiException will be set to the Future if there is underlying permanent error.