Class AckBatchingSubscriber (0.1.1)

Version 0.1.1

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