Package com.google.cloud.spring.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

  • Method Summary

    Modifier and Type
    Method
    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 Details

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