Package io.micronaut.gcp.pubsub.bind

Class DefaultPubSubAcknowledgement

java.lang.Object

io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement

All Implemented Interfaces:

io.micronaut.messaging.Acknowledgement

public class DefaultPubSubAcknowledgement
extends 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

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 Details

DefaultPubSubAcknowledgement

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

Method Details

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.