Package io.micronaut.gcp.pubsub.bind

Class DefaultPubSubAcknowledgement

  • All Implemented Interfaces:
    io.micronaut.messaging.Acknowledgement
    public class DefaultPubSubAcknowledgement
extends java.lang.Object
implements io.micronaut.messaging.Acknowledgement
    Defaul implementation of Acknowledgement contract.
    Since:
    2.0.0
    Author:
    Vinicius Carvalho

    • Constructor Summary

      Constructors 
      Constructor Description
      DefaultPubSubAcknowledgement​(com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void ack()  
      boolean isClientAck()  
      void nack()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • DefaultPubSubAcknowledgement

        public DefaultPubSubAcknowledgement​(com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)

    • Method Detail

      • ack

        public void ack()
         throws io.micronaut.messaging.exceptions.MessageAcknowledgementException
        Specified by:
        ack in interface io.micronaut.messaging.Acknowledgement
        Throws:
        io.micronaut.messaging.exceptions.MessageAcknowledgementException

      • nack

        public void nack()
          throws io.micronaut.messaging.exceptions.MessageAcknowledgementException
        Specified by:
        nack in interface io.micronaut.messaging.Acknowledgement
        Throws:
        io.micronaut.messaging.exceptions.MessageAcknowledgementException

      • isClientAck

        public boolean isClientAck()
        Returns:
        if the client has ack/nack the message.