Class RoutingPublisher (1.14.1) 

public class RoutingPublisher extends ProxyService implements Publisher<MessageMetadata>

Inheritance

java.lang.Object > AbstractApiService > ProxyService > RoutingPublisher

Implements

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

Methods

cancelOutstandingPublishes()

public void cancelOutstandingPublishes()

flush()

public void flush()
Exceptions
Type Description
IOException

publish(PubSubMessage message)

public ApiFuture<MessageMetadata> publish(PubSubMessage message)
Parameter
Name Description
message PubSubMessage
Returns
Type Description
ApiFuture<MessageMetadata>