Interface CloudPubSubSubscriber (1.0.0) 

public interface CloudPubSubSubscriber extends AutoCloseable

An interface for clients that want to subscribe to messages from to Google Cloud Pub/Sub.

Implements

AutoCloseable

Methods

ackMessages(Collection<String> ackIds)

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

close()

public abstract void close()

pull()

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