public class PubSubSubscriberFactoryForEmulator extends Object implements PubSubSubscriberFactory
Constructor and Description |
---|
PubSubSubscriberFactoryForEmulator(String hostAndPort,
String project,
String subscription,
int retries,
java.time.Duration timeout,
int maxMessagesPerPull) |
Modifier and Type | Method and Description |
---|---|
PubSubSubscriber |
getSubscriber(com.google.auth.Credentials credentials)
Creates a new SubscriberStub using the EventLoopGroup and credentials.
|
public PubSubSubscriber getSubscriber(com.google.auth.Credentials credentials) throws IOException
PubSubSubscriberFactory
getSubscriber
in interface PubSubSubscriberFactory
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.