org.apache.beam.sdk.io.gcp.pubsub

Interface PubsubClient.PubsubClientFactory

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

PubsubTestClient.PubsubTestClientFactory

Enclosing class:

PubsubClient

public static interface PubsubClient.PubsubClientFactory
extends java.io.Serializable

Factory for creating clients.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getKind() Return the display name for this factory.
PubsubClient	newClient(@Nullable java.lang.String timestampAttribute, @Nullable java.lang.String idAttribute, PubsubOptions options) Construct a new Pubsub client.

Method Detail

newClient

PubsubClient newClient(@Nullable java.lang.String timestampAttribute,
                       @Nullable java.lang.String idAttribute,
                       PubsubOptions options)
                throws java.io.IOException

Construct a new Pubsub client. It should be closed via Closeable.close() in order to ensure tidy cleanup of underlying netty resources (or use the try-with-resources construct). Uses options to derive pubsub endpoints and application credentials. If non-null, use timestampAttribute and idAttribute to store custom timestamps/ids within message metadata.

Throws:

java.io.IOException

getKind

java.lang.String getKind()

Return the display name for this factory. Eg "Json", "gRPC".