Class AckBatchingSubscriber (1.2.0)

public class AckBatchingSubscriber implements CloudPubSubSubscriber

Inheritance

java.lang.Object > AckBatchingSubscriber

public AckBatchingSubscriber(CloudPubSubSubscriber underlying, AckBatchingSubscriber.AlarmFactory alarmFactory)

Parameters
Name	Description
`underlying`	`CloudPubSubSubscriber`
`alarmFactory`	`com.google.pubsub.kafka.source.AckBatchingSubscriber.AlarmFactory`

public synchronized ApiFuture<Empty> ackMessages(Collection<String> ackIds)

Parameter
Name	Description
`ackIds`	`Collection<String>`

Returns
Type	Description
`ApiFuture<Empty>`

public void close()

public ApiFuture<List<ReceivedMessage>> pull()

Returns
Type	Description
`ApiFuture<List<com.google.pubsub.v1.ReceivedMessage>>`