Class PublisherImpl (1.4.12) 

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>

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

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

stop()

protected void stop()
Overrides

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)
Parameter
Name Description
streamError CheckedApiException