org.apache.flink.streaming.connectors.gcp.pubsub.common

Interface PubSubSubscriberFactory

All Superinterfaces:

Serializable

All Known Implementing Classes:

PubSubSubscriberFactoryForEmulator

public interface PubSubSubscriberFactory
extends Serializable

A factory class to create a SubscriberStub. This allows for customized Subscribers with for instance tweaked configurations. Note: this class needs to be serializable.

Method Summary

Modifier and Type	Method and Description
PubSubSubscriber	getSubscriber(com.google.auth.Credentials credentials) Creates a new SubscriberStub using the EventLoopGroup and credentials.

Method Detail

getSubscriber

PubSubSubscriber getSubscriber(com.google.auth.Credentials credentials)
                        throws IOException

Creates a new SubscriberStub using the EventLoopGroup and credentials. If the SubscriberStub uses a EventLoopGroup, as many Grpc classes do, this EventLoopGroup should be used.

Throws:

IOException