Class SequenceAssigningPublisher (1.12.9)

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>

Methods

cancelOutstandingPublishes()

public void cancelOutstandingPublishes()

flush()

public void flush()
Exceptions
TypeDescription
IOException

publish(PubSubMessage message)

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