org.springframework.cloud.gcp.pubsub.support

Class AcknowledgeablePubsubMessage

java.lang.Object

org.springframework.cloud.gcp.pubsub.support.AcknowledgeablePubsubMessage

public class AcknowledgeablePubsubMessage
extends Object

A PubsubMessage wrapper that allows it to be acknowledged.

To acknowledge AcknowledgeablePubsubMessage in bulk, using a PubSubOperations.ack(java.util.Collection) is recommended. To do that, a user must first extract the ack IDs and group them by subscription name.

Author:

João André Martins

Constructor Summary

Constructors

Constructor and Description
AcknowledgeablePubsubMessage(com.google.pubsub.v1.PubsubMessage message, String ackId, String subscriptionName, com.google.cloud.pubsub.v1.stub.SubscriberStub subscriberStub)

Method Summary

Modifier and Type	Method and Description
void	ack()
String	getAckId()
com.google.pubsub.v1.PubsubMessage	getPubsubMessage()
String	getSubscriptionName()
void	nack()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AcknowledgeablePubsubMessage

public AcknowledgeablePubsubMessage(com.google.pubsub.v1.PubsubMessage message,
                                    String ackId,
                                    String subscriptionName,
                                    com.google.cloud.pubsub.v1.stub.SubscriberStub subscriberStub)

Method Detail

getPubsubMessage

public com.google.pubsub.v1.PubsubMessage getPubsubMessage()

getAckId

public String getAckId()

getSubscriptionName

public String getSubscriptionName()

ack

public void ack()

nack

public void nack()