org.apache.beam.it.gcp.pubsub

Class PubsubPublisherFactory

java.lang.Object

org.apache.beam.it.gcp.pubsub.PubsubPublisherFactory

public class PubsubPublisherFactory
extends java.lang.Object

Client for building Pub/Sub publishers.

The class provides an interaction with the real Pub/Sub client, with operations related to creating a Pub/Sub Publisher.

Method Summary

Modifier and Type	Method and Description
com.google.cloud.pubsub.v1.Publisher	createPublisher(com.google.pubsub.v1.TopicName topic) Create a Publisher instance for the given topic reference.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createPublisher

public com.google.cloud.pubsub.v1.Publisher createPublisher(com.google.pubsub.v1.TopicName topic)

Create a Publisher instance for the given topic reference.