cn.com.antcloud.api.mq.v2_0_0.model

类 ConsumeQueueOffset

java.lang.Object

cn.com.antcloud.api.mq.v2_0_0.model.ConsumeQueueOffset

public class ConsumeQueueOffset
extends Object

队列的消费offset相关信息

构造器概要

构造器

构造器和说明
ConsumeQueueOffset()

方法概要

限定符和类型	方法和说明
Long	getAccumulate() 消息堆积数
String	getBrokerName() queue所在broker的名字
Long	getBrokerOffset() 消费位点
String	getClientAddr() 消费端地址
String	getClientId() 消费者客户端id
Long	getConsumerOffset() 消费端offset
Long	getDifference() queue位点和消费端位点差
Long	getLastTimestamp() 最后时间（时间戳）
Long	getQueueId() queue id
String	getTopic() topic
void	setAccumulate(Long accumulate) 消息堆积数
void	setBrokerName(String brokerName) queue所在broker的名字
void	setBrokerOffset(Long brokerOffset) 消费位点
void	setClientAddr(String clientAddr) 消费端地址
void	setClientId(String clientId) 消费者客户端id
void	setConsumerOffset(Long consumerOffset) 消费端offset
void	setDifference(Long difference) queue位点和消费端位点差
void	setLastTimestamp(Long lastTimestamp) 最后时间（时间戳）
void	setQueueId(Long queueId) queue id
void	setTopic(String topic) topic

从类继承的方法 java.lang.Object

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

构造器详细资料

ConsumeQueueOffset

public ConsumeQueueOffset()

方法详细资料

getTopic

public String getTopic()

topic

setTopic

public void setTopic(String topic)

topic

getBrokerName

public String getBrokerName()

queue所在broker的名字

setBrokerName

public void setBrokerName(String brokerName)

queue所在broker的名字

getQueueId

public Long getQueueId()

queue id

setQueueId

public void setQueueId(Long queueId)

queue id

getBrokerOffset

public Long getBrokerOffset()

消费位点

setBrokerOffset

public void setBrokerOffset(Long brokerOffset)

消费位点

getConsumerOffset

public Long getConsumerOffset()

消费端offset

setConsumerOffset

public void setConsumerOffset(Long consumerOffset)

消费端offset

getLastTimestamp

public Long getLastTimestamp()

最后时间（时间戳）

setLastTimestamp

public void setLastTimestamp(Long lastTimestamp)

最后时间（时间戳）

getClientAddr

public String getClientAddr()

消费端地址

setClientAddr

public void setClientAddr(String clientAddr)

消费端地址

getClientId

public String getClientId()

消费者客户端id

setClientId

public void setClientId(String clientId)

消费者客户端id

getAccumulate

public Long getAccumulate()

消息堆积数

setAccumulate

public void setAccumulate(Long accumulate)

消息堆积数

getDifference

public Long getDifference()

queue位点和消费端位点差

setDifference

public void setDifference(Long difference)

queue位点和消费端位点差