Class CloudPubSubRoundRobinSubscriber (1.0.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>>`