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 java.lang.Object
implements io.micronaut.messaging.Acknowledgement

Defaul implementation of Acknowledgement contract.

Since:

2.0.0

Author:

Vinicius Carvalho

Constructor Summary

Constructors

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

Method Summary

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