public class PartitionCountWatchingPublisher 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()| Exceptions | |
|---|---|
| Type | Description |
IOException |
|
handlePermanentError(CheckedApiException error)
protected void handlePermanentError(CheckedApiException error)| Parameter | |
|---|---|
| Name | Description |
error |
CheckedApiException |
publish(PubSubMessage message)
public ApiFuture<MessageMetadata> publish(PubSubMessage message)| Parameter | |
|---|---|
| Name | Description |
message |
PubSubMessage |
| Returns | |
|---|---|
| Type | Description |
ApiFuture<MessageMetadata> |
|
stop()
protected void stop()