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

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>>