org.springframework.cloud.gcp.pubsub.integration.inbound

Class PubSubAcknowledgmentCallback

java.lang.Object

org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubAcknowledgmentCallback

All Implemented Interfaces:

org.springframework.integration.acks.AcknowledgmentCallback, org.springframework.integration.acks.SimpleAcknowledgment

public class PubSubAcknowledgmentCallback
extends Object
implements org.springframework.integration.acks.AcknowledgmentCallback

Pub/Sub specific implementation of AcknowledgmentCallback.

AcknowledgmentCallback.isAcknowledged() is implemented for semantic accuracy only, since in Pub/Sub acknowledging a message more than once is not an error.

AcknowledgmentCallback.noAutoAck() is not implemented; the correct way to enable manual acking is through configuring PubSubMessageSource.

Since:

1.2

Author:

Elena Felder

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.acks.AcknowledgmentCallback

org.springframework.integration.acks.AcknowledgmentCallback.Status

Constructor Summary

Constructors

Constructor and Description
PubSubAcknowledgmentCallback(AcknowledgeablePubsubMessage message, AckMode ackMode)

Method Summary

Modifier and Type	Method and Description
void	acknowledge(org.springframework.integration.acks.AcknowledgmentCallback.Status status) In AckMode.AUTO_ACK mode, nacking cannot be done through this callback.
boolean	isAcknowledged()
boolean	isAutoAck()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.acks.AcknowledgmentCallback

acknowledge, noAutoAck

Constructor Detail

PubSubAcknowledgmentCallback

public PubSubAcknowledgmentCallback(AcknowledgeablePubsubMessage message,
                                    AckMode ackMode)

Method Detail

acknowledge

public void acknowledge(org.springframework.integration.acks.AcknowledgmentCallback.Status status)

In AckMode.AUTO_ACK mode, nacking cannot be done through this callback.

Use GcpPubSubHeaders.ORIGINAL_MESSAGE to nack instead.

Specified by:

acknowledge in interface org.springframework.integration.acks.AcknowledgmentCallback

isAutoAck

public boolean isAutoAck()

Specified by:

isAutoAck in interface org.springframework.integration.acks.AcknowledgmentCallback

isAcknowledged

public boolean isAcknowledged()

Specified by:

isAcknowledged in interface org.springframework.integration.acks.AcknowledgmentCallback