Class CachedPublishers (1.0.0)

public class CachedPublishers

Cached Publishers to reuse publisher of same settings in the same task.

Inheritance

java.lang.Object > CachedPublishers

Constructors

CachedPublishers()

public CachedPublishers()

Methods

getOrCreate(PslWriteDataSourceOptions writeOptions)

public synchronized Publisher<MessageMetadata> getOrCreate(PslWriteDataSourceOptions writeOptions)
Parameter
NameDescription
writeOptionsPslWriteDataSourceOptions
Returns
TypeDescription
com.google.cloud.pubsublite.internal.Publisher<com.google.cloud.pubsublite.MessageMetadata>