public class DmsClientConfig
extends java.lang.Object
构造器和说明 |
---|
DmsClientConfig() |
限定符和类型 | 方法和说明 |
---|---|
static java.lang.Object |
ensureGetProperty(java.lang.String key)
获取配置,如果配置项不存在,抛异常
|
static java.lang.String |
getAccessKey()
access key
|
static int |
getBlockedWorkerNum()
阻塞callback执行worker数量
|
static boolean |
getBooleanProperty(java.lang.String key)
获取boolean配置
|
static byte |
getByteProperty(java.lang.String key)
获取byte配置
|
static short |
getClientId()
获取客户端id
|
static java.lang.String |
getClientVersion()
获取客户端版本
|
static int |
getConnectTimeout()
连接超时
|
static int |
getConsumeMaxMsgnum()
一次消费最大消息数限制
|
static int |
getConsumeMaxTimewait()
消费等待最大时间值
|
static int |
getConsumeMinMsgnum()
一次消费最少消息数限制
|
static int |
getConsumeMinTimewait()
消费等待最小时间值
|
static java.lang.String |
getDmsServiceName()
service name
|
static java.lang.String |
getDmsServiceRegion()
service region
|
static float |
getFloatProperty(java.lang.String key)
获取float配置
|
static java.lang.String |
getIamIp()
iam ip
|
static int |
getIamPort()
iam port
|
static java.lang.String |
getIamUri()
iam uri
|
static int |
getIntProperty(java.lang.String key)
获取int配置
|
static java.lang.String |
getKeyStorePath()
获取keystore路径
|
static char[] |
getKeyStorePwd()
获取keystore密码
|
static long |
getLongProperty(java.lang.String key)
获取long配置
|
static int |
getMaxMsgnumProduce()
一次生产最大消息数限制
|
static int |
getMaxPackageSize()
获取请求最大包配置
|
static int |
getMaxSocketBufferSize()
socket发送缓存
|
static int |
getMaxTaskInflight()
最大可同时发送任务数
|
static int |
getMinTaskInflight()
最小可同时发送任务数
|
static java.lang.String |
getNetClient()
获取netclient实现类
|
static java.lang.String |
getProjectId()
project id
|
static int |
getReconnectAttemptInterval()
连接失败重试间隔
|
static int |
getReconnectAttemptTimes()
连接失败重试次数
|
static int |
getRequestTimeout()
请求超时时间
|
static java.lang.String |
getSecretKey()
secret key
|
static byte |
getSerialType()
获取序列化类型
|
static java.lang.String |
getServerIp()
获取DmsServer ip
|
static int |
getServerPort()
获取DmsServer端口
|
static java.util.List<java.lang.String> |
getSslCipherSuiteList()
ssl加密套件
|
static int |
getStartTimeout()
启动超时时间
|
static java.lang.String |
getStringProperty(java.lang.String key)
获取string配置
|
static java.lang.String |
getTrustStorePath()
获取truststore路径
|
static char[] |
getTrustStorePwd()
获取truststore密码
|
static void |
initConfig(java.util.Properties props)
初始化配置
|
static boolean |
isSsl()
是否开启ssl
|
static boolean |
isTrustAll()
是否信任所有server端
|
static boolean |
isUseOpenSsl()
是否使用openssl
|
static boolean |
requireClientAuth()
是否启用双向认证
|
public static void initConfig(java.util.Properties props)
props
- propspublic static java.lang.String getServerIp()
public static int getServerPort()
public static java.lang.String getClientVersion()
public static java.lang.String getNetClient()
public static byte getSerialType()
public static int getIntProperty(java.lang.String key)
key
- 配置keypublic static long getLongProperty(java.lang.String key)
key
- 配置keypublic static float getFloatProperty(java.lang.String key)
key
- 配置keypublic static byte getByteProperty(java.lang.String key)
key
- 配置keypublic static java.lang.String getStringProperty(java.lang.String key)
key
- 配置keypublic static boolean getBooleanProperty(java.lang.String key)
key
- 配置keypublic static java.lang.Object ensureGetProperty(java.lang.String key)
key
- 配置keypublic static short getClientId()
public static int getMaxPackageSize()
public static int getBlockedWorkerNum()
public static char[] getKeyStorePwd()
public static java.lang.String getKeyStorePath()
public static java.lang.String getTrustStorePath()
public static char[] getTrustStorePwd()
public static boolean isSsl()
public static boolean requireClientAuth()
public static boolean isTrustAll()
public static java.util.List<java.lang.String> getSslCipherSuiteList()
public static int getConnectTimeout()
public static int getReconnectAttemptTimes()
public static int getReconnectAttemptInterval()
public static int getMaxSocketBufferSize()
public static int getMaxTaskInflight()
public static int getMinTaskInflight()
public static boolean isUseOpenSsl()
public static java.lang.String getIamIp()
public static java.lang.String getIamUri()
public static int getIamPort()
public static java.lang.String getDmsServiceName()
public static java.lang.String getDmsServiceRegion()
public static int getConsumeMinMsgnum()
public static int getConsumeMaxMsgnum()
public static int getConsumeMinTimewait()
public static int getConsumeMaxTimewait()
public static int getMaxMsgnumProduce()
public static int getRequestTimeout()
public static int getStartTimeout()
public static java.lang.String getProjectId()
public static java.lang.String getAccessKey()
public static java.lang.String getSecretKey()