Class CloudPubSubGRPCSubscriber (1.2.0) 

public class CloudPubSubGRPCSubscriber implements CloudPubSubSubscriber

A CloudPubSubSubscriber that uses gRPC to pull messages from Google Cloud Pub/Sub. This class is not thread-safe.

Inheritance

java.lang.Object > CloudPubSubGRPCSubscriber

Methods

ackMessages(Collection<String> ackIds)

public ApiFuture<Empty> ackMessages(Collection<String> ackIds)
Parameter
NameDescription
ackIdsCollection<String>
Returns
TypeDescription
ApiFuture<Empty>

close()

public void close()

pull()

public ApiFuture<List<ReceivedMessage>> pull()
Returns
TypeDescription
ApiFuture<List<com.google.pubsub.v1.ReceivedMessage>>