Class CloudPubSubRoundRobinSubscriber (1.2.0)

public class CloudPubSubRoundRobinSubscriber implements CloudPubSubSubscriber

A CloudPubSubSubscriber that distributes a single subscription in round-robin fashion over a set of CloudPubSubGRPCSubscribers.

Inheritance

java.lang.Object > CloudPubSubRoundRobinSubscriber

Implements

CloudPubSubSubscriber

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

CloudPubSubRoundRobinSubscriber(int subscriberCount, CredentialsProvider gcpCredentialsProvider, String endpoint, ProjectSubscriptionName subscriptionName, int cpsMaxBatchSize)

public CloudPubSubRoundRobinSubscriber(int subscriberCount, CredentialsProvider gcpCredentialsProvider, String endpoint, ProjectSubscriptionName subscriptionName, int cpsMaxBatchSize)

Parameters
Name	Description
subscriberCount	int
gcpCredentialsProvider	CredentialsProvider
endpoint	String
subscriptionName	com.google.pubsub.v1.ProjectSubscriptionName
cpsMaxBatchSize	int

Methods

ackMessages(Collection<String> ackIds)

public ApiFuture<Empty> ackMessages(Collection<String> ackIds)

Parameter
Name	Description
ackIds	Collection<String>

Returns
Type	Description
ApiFuture<Empty>

close()

public void close()

pull()

public ApiFuture<List<ReceivedMessage>> pull()

Returns
Type	Description
ApiFuture<List<com.google.pubsub.v1.ReceivedMessage>>