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

类 ConsumerConnectionInfoDTO

java.lang.Object

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

public class ConsumerConnectionInfoDTO
extends Object

该集群在线客户端详细信息，包含 Jstack、消费 RT 时间等信息

构造器概要

构造器

构造器和说明
ConsumerConnectionInfoDTO()

方法概要

限定符和类型	方法和说明
String	getClientId() 消费实例的 ID
String	getConnection() 连接信息
String	getConsumeType() PUSH/PULL
List<ThreadTrackDTO>	getJstack() Jstack 堆栈信息
String	getLanguage() 客户端语言
Long	getLastTimestamp() 最后更新时间
String	getMessageModel() 消费模型，取值说明如下：CLUSTERING：集群消费模式；BROADCASTING：广播消费模式。
List<ConsumerRunningDataDTO>	getRunningDataList() 实时状态统计
Long	getStartTimestamp() 开始时间
List<SubscriptionDTO>	getSubscriptionSet() 订阅关系集合
Long	getThreadCount() 消费线程数
String	getVersion() 客户端版本号
void	setClientId(String clientId) 消费实例的 ID
void	setConnection(String connection) 连接信息
void	setConsumeType(String consumeType) PUSH/PULL
void	setJstack(List<ThreadTrackDTO> jstack) Jstack 堆栈信息
void	setLanguage(String language) 客户端语言
void	setLastTimestamp(Long lastTimestamp) 最后更新时间
void	setMessageModel(String messageModel) 消费模型，取值说明如下：CLUSTERING：集群消费模式；BROADCASTING：广播消费模式。
void	setRunningDataList(List<ConsumerRunningDataDTO> runningDataList) 实时状态统计
void	setStartTimestamp(Long startTimestamp) 开始时间
void	setSubscriptionSet(List<SubscriptionDTO> subscriptionSet) 订阅关系集合
void	setThreadCount(Long threadCount) 消费线程数
void	setVersion(String version) 客户端版本号

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

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

构造器详细资料

ConsumerConnectionInfoDTO

public ConsumerConnectionInfoDTO()

方法详细资料

getClientId

public String getClientId()

消费实例的 ID

setClientId

public void setClientId(String clientId)

消费实例的 ID

getConnection

public String getConnection()

连接信息

setConnection

public void setConnection(String connection)

连接信息

getConsumeType

public String getConsumeType()

PUSH/PULL

setConsumeType

public void setConsumeType(String consumeType)

PUSH/PULL

getJstack

public List<ThreadTrackDTO> getJstack()

Jstack 堆栈信息

setJstack

public void setJstack(List<ThreadTrackDTO> jstack)

Jstack 堆栈信息

getLanguage

public String getLanguage()

客户端语言

setLanguage

public void setLanguage(String language)

客户端语言

getLastTimestamp

public Long getLastTimestamp()

最后更新时间

setLastTimestamp

public void setLastTimestamp(Long lastTimestamp)

最后更新时间

getMessageModel

public String getMessageModel()

消费模型，取值说明如下：CLUSTERING：集群消费模式；BROADCASTING：广播消费模式。

setMessageModel

public void setMessageModel(String messageModel)

消费模型，取值说明如下：CLUSTERING：集群消费模式；BROADCASTING：广播消费模式。

getRunningDataList

public List<ConsumerRunningDataDTO> getRunningDataList()

实时状态统计

setRunningDataList

public void setRunningDataList(List<ConsumerRunningDataDTO> runningDataList)

实时状态统计

getStartTimestamp

public Long getStartTimestamp()

开始时间

setStartTimestamp

public void setStartTimestamp(Long startTimestamp)

开始时间

getSubscriptionSet

public List<SubscriptionDTO> getSubscriptionSet()

订阅关系集合

setSubscriptionSet

public void setSubscriptionSet(List<SubscriptionDTO> subscriptionSet)

订阅关系集合

getThreadCount

public Long getThreadCount()

消费线程数

setThreadCount

public void setThreadCount(Long threadCount)

消费线程数

getVersion

public String getVersion()

客户端版本号

setVersion

public void setVersion(String version)

客户端版本号