public class SinglePartitionPublisher extends ProxyService implements Publisher<MessageMetadata>
Implements
com.google.cloud.pubsublite.internal.Publisher<com.google.cloud.pubsublite.MessageMetadata>Methods
cancelOutstandingPublishes()
public void cancelOutstandingPublishes()
flush()
public void flush()
Type | Description |
IOException |
publish(Message message)
public ApiFuture<MessageMetadata> publish(Message message)
Name | Description |
message | Message |
Type | Description |
ApiFuture<MessageMetadata> |