Class SequenceAssigningPublisher (1.16.5)

1.16.5 (latest) 1.16.2 1.15.21 1.14.8 1.13.8 1.12.22 1.11.2 1.10.0 1.9.4 1.8.0 1.7.1 1.6.3 1.5.5 1.4.12

public class SequenceAssigningPublisher extends ProxyService implements Publisher<Offset>

A publisher that assigns sequence numbers to messages and delegates to an underlying SequencedPublisher.

Inheritance

java.lang.Object > AbstractApiService > ProxyService > SequenceAssigningPublisher

Implements

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

Inherited Members

AbstractApiService.addListener(ApiService.Listener,Executor)

AbstractApiService.awaitRunning()

AbstractApiService.awaitRunning(long,TimeUnit)

AbstractApiService.awaitTerminated()

AbstractApiService.awaitTerminated(long,TimeUnit)

AbstractApiService.failureCause()

AbstractApiService.isRunning()

AbstractApiService.notifyFailed(Throwable)

AbstractApiService.notifyStarted()

AbstractApiService.notifyStopped()

AbstractApiService.startAsync()

AbstractApiService.state()

AbstractApiService.stopAsync()

ProxyService.<T>addServices(Collection<T>)

ProxyService.addServices(ApiService)

ProxyService.doStart()

ProxyService.doStop()

ProxyService.handlePermanentError(CheckedApiException)

ProxyService.onPermanentError(CheckedApiException)

ProxyService.start()

ProxyService.stop()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

cancelOutstandingPublishes()

public void cancelOutstandingPublishes()

flush()

public void flush()

Exceptions
Type	Description
IOException

publish(PubSubMessage message)

public synchronized ApiFuture<Offset> publish(PubSubMessage message)

Parameter
Name	Description
message	PubSubMessage

Returns
Type	Description
ApiFuture<Offset>