public class SequenceAssigningPublisher extends ProxyService implements Publisher<Offset>A publisher that assigns sequence numbers to messages and delegates to an underlying SequencedPublisher.
Implements
com.google.cloud.pubsublite.internal.Publisher<com.google.cloud.pubsublite.Offset>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> |
|