跳过导航链接
A B C D E F G H I L M N O P Q R S T U V W 

G

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
A B C D E F G H I L M N O P Q R S T U V W 
跳过导航链接