Class AmqpMessageSource.AmqpAckCallback
java.lang.Object
org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckCallback
- All Implemented Interfaces:
org.springframework.integration.acks.AcknowledgmentCallback,org.springframework.integration.acks.SimpleAcknowledgment
- Enclosing class:
- AmqpMessageSource
public static class AmqpMessageSource.AmqpAckCallback
extends java.lang.Object
implements org.springframework.integration.acks.AcknowledgmentCallback
-
Nested Class Summary
-
Constructor Summary
Constructors Constructor Description AmqpAckCallback(AmqpMessageSource.AmqpAckInfo ackInfo) -
Method Summary
Modifier and Type Method Description voidacknowledge(org.springframework.integration.acks.AcknowledgmentCallback.Status status)protected AmqpMessageSource.AmqpAckInfogetAckInfo()booleanisAcknowledged()booleanisAutoAck()voidnoAutoAck()protected voidsetAcknowledged(boolean acknowledged)java.lang.StringtoString()
-
Constructor Details
-
Method Details
-
getAckInfo
-
setAcknowledged
protected void setAcknowledged(boolean acknowledged) -
isAcknowledged
public boolean isAcknowledged()- Specified by:
isAcknowledgedin interfaceorg.springframework.integration.acks.AcknowledgmentCallback
-
noAutoAck
public void noAutoAck()- Specified by:
noAutoAckin interfaceorg.springframework.integration.acks.AcknowledgmentCallback
-
isAutoAck
public boolean isAutoAck()- Specified by:
isAutoAckin interfaceorg.springframework.integration.acks.AcknowledgmentCallback
-
acknowledge
public void acknowledge(org.springframework.integration.acks.AcknowledgmentCallback.Status status)- Specified by:
acknowledgein interfaceorg.springframework.integration.acks.AcknowledgmentCallback
-
toString
public java.lang.String toString()- Overrides:
toStringin classjava.lang.Object
-