Class AckBatchingSubscriber (1.2.0) 

public class AckBatchingSubscriber implements CloudPubSubSubscriber

Inheritance

java.lang.Object > AckBatchingSubscriber

Constructors

AckBatchingSubscriber(CloudPubSubSubscriber underlying, AckBatchingSubscriber.AlarmFactory alarmFactory)

public AckBatchingSubscriber(CloudPubSubSubscriber underlying, AckBatchingSubscriber.AlarmFactory alarmFactory)
Parameters
Name Description
underlying CloudPubSubSubscriber
alarmFactory com.google.pubsub.kafka.source.AckBatchingSubscriber.AlarmFactory

Methods

ackMessages(Collection<String> ackIds)

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