Package com.google.cloud.pubsublite.internal

Interface Publisher<ResponseT>

All Superinterfaces:

com.google.api.core.ApiService, Flushable

All Known Implementing Classes:

ApiExceptionPublisher, PartitionCountWatchingPublisher, RoutingPublisher, SequenceAssigningPublisher, SinglePartitionPublisher

public interface Publisher<ResponseT>
extends com.google.api.core.ApiService, Flushable

A generic PubSub Lite publisher. Errors are handled out of band. Thread safe.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.api.core.ApiService

com.google.api.core.ApiService.Listener, com.google.api.core.ApiService.State

Method Summary

Modifier and Type	Method	Description
void	cancelOutstandingPublishes()
com.google.api.core.ApiFuture<ResponseT>	publish(PubSubMessage message)

Methods inherited from interface com.google.api.core.ApiService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Methods inherited from interface java.io.Flushable

flush

Method Detail

publish

com.google.api.core.ApiFuture<ResponseT> publish(PubSubMessage message)

cancelOutstandingPublishes

void cancelOutstandingPublishes()