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

Class PublisherImpl (1.5.5)

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

Inheritance

java.lang.Object > AbstractApiService > ProxyService > PublisherImpl

Implements

com.google.cloud.pubsublite.internal.Publisher<com.google.cloud.pubsublite.Offset>, com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver<com.google.cloud.pubsublite.Offset>

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()

flush()

public void flush()

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)

Parameter

Name	Description
error	`CheckedApiException`

Overrides

ProxyService.handlePermanentError(CheckedApiException error)

onClientResponse(Offset value)

public void onClientResponse(Offset value)

Parameter

Name	Description
value	`Offset`

Exceptions

Type	Description
CheckedApiException

publish(Message message)

public ApiFuture<Offset> publish(Message message)

Parameter

Name	Description
message	`Message`

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`