Class PublisherImpl (1.10.0)

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(Message message, PublishSequenceNumber sequenceNumber)

public ApiFuture<Offset> publish(Message 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`	`Message`
`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`