- GBK - 类 中的静态变量com.huawei.dms.Constant
-
GBK
- GBK - 类 中的静态变量com.huawei.dms.protocol.ProtocolConstant
-
GBK
- get() - 类 中的方法com.huawei.dms.client.DmsRequestFuture
-
调用get会阻塞等待结果响应
- get(long, TimeUnit) - 类 中的方法com.huawei.dms.client.DmsRequestFuture
-
调用get会阻塞等待结果响应,最长等待指定时间
- getAccessKey() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
access key
- getAfterHook(Operation) - 类 中的静态方法com.huawei.dms.client.hooks.DmsHookManager
-
获取api后置钩子
- getAttr(String) - 类 中的方法com.huawei.dms.client.hooks.DmsApiContext
-
获取上下文参数
- getAttrFilterList() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getAttributes() - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- getAttributes() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- getBeforeHook(Operation) - 类 中的静态方法com.huawei.dms.client.hooks.DmsHookManager
-
获取api前置钩子
- getBlockedWorkerNum() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
阻塞callback执行worker数量
- getBody() - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- getBody() - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
- getBody() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- getBooleanProperty(String) - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取boolean配置
- getBroadcastGroup(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
<一句话功能简述>
<功能详细描述>
- getByteProperty(String) - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取byte配置
- getBytes() - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
获取序列化字节
- getBytes() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
获取序列化字节
- getClientId() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取客户端id
- getClientId() - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
获取clientID
- getClientId() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- getClientType() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- getClientVersion() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取客户端版本
- getCode() - 异常错误 中的方法com.huawei.dms.protocol.exception.ProtocolException
-
- getConnectTimeout() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
连接超时
- getConsumeId() - 类 中的方法com.huawei.dms.client.consume.DmsConsumerImpl
-
- getConsumeId() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getConsumeMaxMsgnum() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
一次消费最大消息数限制
- getConsumeMaxTimewait() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
消费等待最大时间值
- getConsumeMinMsgnum() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
一次消费最少消息数限制
- getConsumeMinTimewait() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
消费等待最小时间值
- getConsumeMode() - 类 中的方法com.huawei.dms.client.consume.DmsConsumerImpl
-
- getConsumeMode() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getConsumerId() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getConsumerVersion() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getDlReveives() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getDmsServiceName() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
service name
- getDmsServiceRegion() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
service region
- getError() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceResult
-
- getErrorCode() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceResult
-
- getErrorMsg() - 异常错误 中的方法com.huawei.dms.protocol.exception.ProtocolException
-
返回错误json串
- getExtField() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- getFail() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitResult
-
- getFailedCount() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- getField(String) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
获取字段值
- getFloatProperty(String) - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取float配置
- getFuture() - 类 中的方法com.huawei.dms.client.DmsTask
-
- getGroup() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getHandler() - 类 中的方法com.huawei.dms.client.entity.DmsConsumeResult
-
getHandler
- getHandler() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitItem
-
- getHandler() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
getHandler
- getHead() - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
- getHeader(String) - 类 中的方法com.huawei.dms.client.utils.DmsClientHttpResponse
-
获取heander值
- getHeadField(String) - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
获取header字段
- getHttpClient(boolean) - 类 中的静态方法com.huawei.dms.client.utils.HttpUtil
-
httpclient
- getIamIp() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
iam ip
- getIamPort() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
iam port
- getIamUri() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
iam uri
- getInfightTaskCount() - 接口 中的方法com.huawei.dms.client.transport.DmsNetClient
-
获取正在处理任务数
- getInfightTaskCount() - 类 中的方法com.huawei.dms.client.transport.vertx.DmsVertxNetClient
-
- getInstance() - 类 中的静态方法com.huawei.dms.client.cache.CacheManager
-
获取cacheManager
缓存失效时间,默认一个小时
检查缓存项时间间隔,默认一分钟
- getInstance(long, int) - 类 中的静态方法com.huawei.dms.client.cache.CacheManager
-
单例获取cacheManager实例
- getInstance() - 类 中的静态方法com.huawei.dms.client.utils.DmsBlockedWorker
-
这里使用懒汉,是为了使用时才创建线程池,如果不用就不创建多余的线程
- getIntProperty(String) - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取int配置
- getItem(String) - 类 中的方法com.huawei.dms.client.cache.CacheManager
-
获取缓存项
- getKey() - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- getKey() - 类 中的方法com.huawei.dms.protocol.produce.DmsConsumeMessage
-
- getKey() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- getKey() - 类 中的方法com.huawei.dms.protocol.produce.RedeliverProduceRecord
-
- getKeyBytes() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- getKeyByteSize() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- getKeyStorePath() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取keystore路径
- getKeyStorePwd() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取keystore密码
- getLongProperty(String) - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取long配置
- getLongPullTime() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getMaxBytes() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getMaxMsgnumProduce() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
一次生产最大消息数限制
- getMaxPackageSize() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取请求最大包配置
- getMaxRecords() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getMaxSocketBufferSize() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
socket发送缓存
- getMaxTaskInflight() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
最大可同时发送任务数
- getMessage() - 类 中的方法com.huawei.dms.client.entity.DmsConsumeResult
-
返回 message
- getMessage() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitRequest
-
- getMessage() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
返回 message
- getMessageBytes() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
返回 messageBytes
- getMessageByteSize() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
返回 messageByteSize
- getMessages() - 类 中的方法com.huawei.dms.client.entity.DmsProduceRequest
-
- getMessages() - 类 中的方法com.huawei.dms.protocol.produce.DmsBatchProduceRequest
-
- getMinTaskInflight() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
最小可同时发送任务数
- getMsLoadTick() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- getMsPullTime() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getMsWaitCommit() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getNetClient() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取netclient实现类
- getNetSocket() - 类 中的方法com.huawei.dms.protocol.vertx.DmsVertxNetSocket
-
- getOffset() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
返回 offset
- getOffset() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getOper() - 类 中的方法com.huawei.dms.client.hooks.DmsApiContext
-
- getOper() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- getOper(byte) - 枚举 中的静态方法com.huawei.dms.protocol.Operation
-
getOper
- getOperCode() - 枚举 中的方法com.huawei.dms.protocol.Operation
-
oper 编码
- getOperEntity() - 类 中的方法com.huawei.dms.client.DmsTask
-
- getOperId() - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
获取操作码
- getOperId() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- getPartition() - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- getPartition() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getPartition() - 类 中的方法com.huawei.dms.protocol.produce.DmsConsumeMessage
-
- getPartition() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- getPartition() - 类 中的方法com.huawei.dms.protocol.produce.RedeliverProduceRecord
-
- getProjectId() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
project id
- getReconnectAttemptInterval() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
连接失败重试间隔
- getReconnectAttemptTimes() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
连接失败重试次数
- getRedeliverTimes() - 类 中的方法com.huawei.dms.client.entity.DmsConsumeResult
-
返回消息重投次数
- getRedeliverTimes() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
返回 getRedeliverTimes
- getRedeliverTimes() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getRedeliverTimes() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- getRequestTimeout() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
请求超时时间
- getResponseBody() - 类 中的方法com.huawei.dms.client.utils.DmsClientHttpResponse
-
- getSecretKey() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
secret key
- getSerialType() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取序列化类型
- getSerialType() - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
获取序列化类型
- getSerialType() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- getServerIp() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取DmsServer ip
- getServerPort() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取DmsServer端口
- getServerSuccessCount() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitResult
-
需要提交的成功数,
正常场景下,和success相等
死信打开场景下,该值等于用户提交的成功数加上成功进入死信的消息数
- getSslCipherSuiteList() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
ssl加密套件
- getStartTimeout() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
启动超时时间
- getState() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceResult
-
- getStatus() - 类 中的方法com.huawei.dms.client.DmsTask
-
- getStatusCode() - 类 中的方法com.huawei.dms.client.utils.DmsClientHttpResponse
-
- getStatusMsg() - 类 中的方法com.huawei.dms.client.utils.DmsClientHttpResponse
-
- getStoreRecord() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- getStringProperty(String) - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取string配置
- getSuccess() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitResult
-
- getTagList() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getTagList() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getTags() - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- getTags() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- getTagType() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- getTagType() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getTaskId() - 类 中的方法com.huawei.dms.client.DmsTask
-
获取任务ID
- getTimestamp() - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- getTimestamp() - 类 中的方法com.huawei.dms.protocol.produce.DmsConsumeMessage
-
- getTimestamp() - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- getToken(String, String, String) - 类 中的静态方法com.huawei.dms.client.auth.IamTokenUtils
-
通过ak、sk获取用户token
- getTopic() - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- getTrustStorePath() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取truststore路径
- getTrustStorePwd() - 类 中的静态方法com.huawei.dms.client.config.DmsClientConfig
-
获取truststore密码
- getTypeCode() - 枚举 中的方法com.huawei.dms.protocol.ClientType
-
获取类型编码
这里需注意,最多限定定义255种类型
- getVersion() - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- GROUP_PARAM - 类 中的静态变量com.huawei.dms.Constant
-
GROUP_PARAM