Some or all of the information on this page might not apply to Trusted Cloud by S3NS. See Differences from Google Cloud for more details.

Class PublisherImpl (1.15.12)

public final class PublisherImpl extends ProxyService implements SequencedPublisher<Offset>, RetryingConnectionObserver<MessagePublishResponse>

Inheritance

java.lang.Object > AbstractApiService > ProxyService > PublisherImpl

Implements

com.google.cloud.pubsublite.internal.SequencedPublisher<com.google.cloud.pubsublite.Offset>, com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver<com.google.cloud.pubsublite.proto.MessagePublishResponse>

Inherited Members

AbstractApiService.addListener(ApiService.Listener,Executor)

AbstractApiService.awaitRunning()

AbstractApiService.awaitRunning(long,TimeUnit)

AbstractApiService.awaitTerminated()

AbstractApiService.awaitTerminated(long,TimeUnit)

AbstractApiService.failureCause()

AbstractApiService.isRunning()

AbstractApiService.notifyFailed(Throwable)

AbstractApiService.notifyStarted()

AbstractApiService.notifyStopped()

AbstractApiService.startAsync()

AbstractApiService.state()

AbstractApiService.stopAsync()

ProxyService.<T>addServices(Collection<T>)

ProxyService.addServices(ApiService)

ProxyService.doStart()

ProxyService.doStop()

ProxyService.handlePermanentError(CheckedApiException)

ProxyService.onPermanentError(CheckedApiException)

ProxyService.start()

ProxyService.stop()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

PublisherImpl(StreamFactories.PublishStreamFactory streamFactory, InitialPublishRequest initialRequest, BatchingSettings batchingSettings)

public PublisherImpl(StreamFactories.PublishStreamFactory streamFactory, InitialPublishRequest initialRequest, BatchingSettings batchingSettings)

Parameters
Name	Description
`streamFactory`	`StreamFactories.PublishStreamFactory`
`initialRequest`	`InitialPublishRequest`
`batchingSettings`	`BatchingSettings`

Methods

cancelOutstandingPublishes()

public void cancelOutstandingPublishes()

Attempts to cancel all outstanding publishes.

flush()

public void flush()

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)

Parameter
Name	Description
`error`	`CheckedApiException`

Overrides

ProxyService.handlePermanentError(CheckedApiException error)

onClientResponse(MessagePublishResponse publishResponse)

public void onClientResponse(MessagePublishResponse publishResponse)

Parameter
Name	Description
`publishResponse`	`MessagePublishResponse`

Exceptions
Type	Description
`CheckedApiException`

publish(PubSubMessage message, PublishSequenceNumber sequenceNumber)

public ApiFuture<Offset> publish(PubSubMessage message, PublishSequenceNumber sequenceNumber)

Publish a new message with an assigned sequence number.

Behavior is undefined if a call to flush() is outstanding or close() has already been called. This method never blocks.

Guarantees that if a single publish future has an exception set, all publish calls made after that will also have an exception set.

Parameters
Name	Description
`message`	`PubSubMessage`
`sequenceNumber`	`PublishSequenceNumber`

Returns
Type	Description
`ApiFuture<Offset>`

start()

protected void start()

Overrides

ProxyService.start()

stop()

protected void stop()

Overrides

ProxyService.stop()

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)

Parameter
Name	Description
`streamError`	`CheckedApiException`