org.springframework.cloud.stream.binder.rocketmq.consuming

Class Acknowledgement

java.lang.Object

org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

public class Acknowledgement
extends Object

Author:

Timur Valiev, Jim

Constructor Summary

Constructors

Constructor and Description
Acknowledgement()

Method Summary

Modifier and Type	Method and Description
static Acknowledgement	buildConcurrentlyInstance()
static Acknowledgement	buildOrderlyInstance()
Integer	getConsumeConcurrentlyDelayLevel()
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus	getConsumeConcurrentlyStatus()
org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus	getConsumeOrderlyStatus()
Long	getConsumeOrderlySuspendCurrentQueueTimeMill()
void	setConsumeConcurrentlyDelayLevel(Integer consumeConcurrentlyDelayLevel)
Acknowledgement	setConsumeConcurrentlyStatus(org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus consumeConcurrentlyStatus)
Acknowledgement	setConsumeOrderlyStatus(org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus consumeOrderlyStatus)
void	setConsumeOrderlySuspendCurrentQueueTimeMill(Long consumeOrderlySuspendCurrentQueueTimeMill)

Methods inherited from class java.lang.Object

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

Constructor Detail

Acknowledgement

public Acknowledgement()

Method Detail

setConsumeConcurrentlyStatus

public Acknowledgement setConsumeConcurrentlyStatus(org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus consumeConcurrentlyStatus)

getConsumeConcurrentlyStatus

public org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus getConsumeConcurrentlyStatus()

getConsumeOrderlyStatus

public org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus getConsumeOrderlyStatus()

setConsumeOrderlyStatus

public Acknowledgement setConsumeOrderlyStatus(org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus consumeOrderlyStatus)

getConsumeConcurrentlyDelayLevel

public Integer getConsumeConcurrentlyDelayLevel()

setConsumeConcurrentlyDelayLevel

public void setConsumeConcurrentlyDelayLevel(Integer consumeConcurrentlyDelayLevel)

getConsumeOrderlySuspendCurrentQueueTimeMill

public Long getConsumeOrderlySuspendCurrentQueueTimeMill()

setConsumeOrderlySuspendCurrentQueueTimeMill

public void setConsumeOrderlySuspendCurrentQueueTimeMill(Long consumeOrderlySuspendCurrentQueueTimeMill)

buildOrderlyInstance

public static Acknowledgement buildOrderlyInstance()

buildConcurrentlyInstance

public static Acknowledgement buildConcurrentlyInstance()