Class PartitionCountWatchingPublisher (1.12.22)

public class PartitionCountWatchingPublisher extends ProxyService implements Publisher<MessageMetadata>

Inheritance

java.lang.Object > AbstractApiService > ProxyService > PartitionCountWatchingPublisher

Implements

com.google.cloud.pubsublite.internal.Publisher<com.google.cloud.pubsublite.MessageMetadata>

Methods

cancelOutstandingPublishes()

public void cancelOutstandingPublishes()

flush()

public void flush()
Exceptions
TypeDescription
IOException

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
NameDescription
errorCheckedApiException
Overrides

publish(PubSubMessage message)

public ApiFuture<MessageMetadata> publish(PubSubMessage message)
Parameter
NameDescription
messagePubSubMessage
Returns
TypeDescription
ApiFuture<MessageMetadata>

stop()

protected void stop()
Overrides