Class AckBatchingSubscriber (1.2.0)

Version latest

• 1.2.0 (latest)
• 1.1.0
• 1.0.0
• 0.1.5

public class AckBatchingSubscriber implements CloudPubSubSubscriber

Inheritance

java.lang.Object > AckBatchingSubscriber

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

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