Class CloudPubSubRoundRobinSubscriber (0.1.1)

Version 0.1.1

• 1.2.0 (latest)
• 1.1.0
• 1.0.0
• 0.1.5

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