Class CachedSubscriberClients (0.4.5)

public class CachedSubscriberClients

Singleton class that caches subscriber service clients to be re-used by the same task.

Inheritance

java.lang.Object > CachedSubscriberClients

Static Methods

getOrCreate(PslReadDataSourceOptions readOptions)

public static SubscriberServiceClient getOrCreate(PslReadDataSourceOptions readOptions)
Parameter
NameDescription
readOptionsPslReadDataSourceOptions
Returns
TypeDescription
com.google.cloud.pubsublite.v1.SubscriberServiceClient

Constructors

CachedSubscriberClients()

public CachedSubscriberClients()