org.springframework.integration.amqp.inbound

Class AmqpMessageSource.AmqpAckCallback

java.lang.Object

org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckCallback

All Implemented Interfaces:

AcknowledgmentCallback

Enclosing class:

AmqpMessageSource

public static class AmqpMessageSource.AmqpAckCallback
extends java.lang.Object
implements AcknowledgmentCallback

Nested Class Summary

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

AcknowledgmentCallback.Status

Constructor Summary

Constructors

Constructor and Description
AmqpAckCallback(AmqpMessageSource.AmqpAckInfo ackInfo)

Method Summary

Modifier and Type	Method and Description
void	acknowledge(AcknowledgmentCallback.Status status) Acknowledge the message.
protected AmqpMessageSource.AmqpAckInfo	getAckInfo()
boolean	isAcknowledged() Implementations must implement this to indicate when the ack has been processed by the user so that the framework can auto-ack if needed.
boolean	isAutoAck() Return true if this acknowledgment supports auto ack when it has not been already ack'd by the application.
void	noAutoAck() Disable auto acknowledgment by a SourcePollingChannelAdapter or MessageSourcePollingTemplate.
protected void	setAcknowledged(boolean acknowledged)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpAckCallback

public AmqpAckCallback(AmqpMessageSource.AmqpAckInfo ackInfo)

Method Detail

getAckInfo

protected AmqpMessageSource.AmqpAckInfo getAckInfo()

setAcknowledged

protected void setAcknowledged(boolean acknowledged)

isAcknowledged

public boolean isAcknowledged()

Description copied from interface: AcknowledgmentCallback

Implementations must implement this to indicate when the ack has been processed by the user so that the framework can auto-ack if needed.

Specified by:

isAcknowledged in interface AcknowledgmentCallback

Returns:

true if the message is already acknowledged.

noAutoAck

public void noAutoAck()

Description copied from interface: AcknowledgmentCallback

Disable auto acknowledgment by a SourcePollingChannelAdapter or MessageSourcePollingTemplate. Not all implementations support this - for example, the Kafka message source.

Specified by:

noAutoAck in interface AcknowledgmentCallback

isAutoAck

public boolean isAutoAck()

Description copied from interface: AcknowledgmentCallback

Return true if this acknowledgment supports auto ack when it has not been already ack'd by the application.

Specified by:

isAutoAck in interface AcknowledgmentCallback

Returns:

true if auto ack is supported.

acknowledge

public void acknowledge(AcknowledgmentCallback.Status status)

Description copied from interface: AcknowledgmentCallback

Acknowledge the message.

Specified by:

acknowledge in interface AcknowledgmentCallback

Parameters:

status - the status.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object