Class CachedPublishers (1.0.0)

Version latest

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class CachedPublishers

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

Inheritance

java.lang.Object > CachedPublishers

Inherited Members

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

CachedPublishers()

public CachedPublishers()

Methods

getOrCreate(PslWriteDataSourceOptions writeOptions)

public synchronized Publisher<MessageMetadata> getOrCreate(PslWriteDataSourceOptions writeOptions)

Parameter
Name	Description
writeOptions	PslWriteDataSourceOptions

Returns
Type	Description
com.google.cloud.pubsublite.internal.Publisher<com.google.cloud.pubsublite.MessageMetadata>