org.springframework.cloud.gcp.pubsub.support

Interface BasicAcknowledgeablePubsubMessage

All Known Subinterfaces:

AcknowledgeablePubsubMessage, ConvertedAcknowledgeablePubsubMessage<T>, ConvertedBasicAcknowledgeablePubsubMessage<T>

public interface BasicAcknowledgeablePubsubMessage

A PubsubMessage wrapper that allows it to be acknowledged.

Since:

1.1

Author:

João André Martins, Mike Eltsufin, Doug Hoard, Chengyuan Zhao

Method Summary

Modifier and Type	Method and Description
org.springframework.util.concurrent.ListenableFuture<Void>	ack() Acknowledge (ack) the message asynchronously.
com.google.pubsub.v1.ProjectSubscriptionName	getProjectSubscriptionName() Accessor for the project subscription name of the Pub/Sub message.
com.google.pubsub.v1.PubsubMessage	getPubsubMessage() Accessor for the wrapped PubsubMessage.
org.springframework.util.concurrent.ListenableFuture<Void>	nack() Negatatively achnowledge (nack) the message asynchronously.

Method Detail

getProjectSubscriptionName

com.google.pubsub.v1.ProjectSubscriptionName getProjectSubscriptionName()

Accessor for the project subscription name of the Pub/Sub message.

Returns:

the project subscription name

getPubsubMessage

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

Accessor for the wrapped PubsubMessage.

Returns:

the wrapped Pub/Sub message

ack

org.springframework.util.concurrent.ListenableFuture<Void> ack()

Acknowledge (ack) the message asynchronously.

Returns:

ListenableFuture<Void>}

nack

org.springframework.util.concurrent.ListenableFuture<Void> nack()

Negatatively achnowledge (nack) the message asynchronously.

Returns:

ListenableFuture<Void>}