com.taobao.metamorphosis.client
类 MetaClientConfig

java.lang.Object
  com.taobao.metamorphosis.client.MetaClientConfig

所有已实现的接口：

Serializable

直接已知子类：

ConsumerConfig

public class MetaClientConfig
extends Object
implements Serializable

另请参见：

序列化表格

字段摘要

protected String	serverUrl
protected ZkUtils.ZKConfig	zkConfig

构造方法摘要

MetaClientConfig()

方法摘要

boolean	equals(Object obj)
String	getDiamondPartitionsDataId()
String	getDiamondPartitionsGroup()
Properties	getPartitionsInfo()
long	getRecoverMessageIntervalInMills()
int	getRecoverThreadCount()
String	getServerUrl()
ZkUtils.ZKConfig	getZkConfig()
String	getZkConnect()
int	getZkConnectionTimeoutMs()
String	getZkRoot()
int	getZkSessionTimeoutMs()
int	getZkSyncTimeMs()
int	hashCode()
boolean	isZkEnable()
void	setPartitionsInfo(Properties partitionsInfo) 设置topic的分布情况.
void	setRecoverMessageIntervalInMills(long recoverMessageIntervalInMills)
void	setRecoverThreadCount(int recoverThreadCount)
void	setServerUrl(String serverUrl)
void	setZkConfig(ZkUtils.ZKConfig zkConfig)
void	setZkConnect(String zkConnect)
void	setZkConnectionTimeoutMs(int zkConnectionTimeoutMs)
void	setZkEnable(boolean zkEnable)
void	setZkRoot(String zkRoot)
void	setZkSessionTimeoutMs(int zkSessionTimeoutMs)
void	setZkSyncTimeMs(int zkSyncTimeMs)

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

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

字段详细信息

serverUrl

protected String serverUrl

zkConfig

protected ZkUtils.ZKConfig zkConfig

构造方法详细信息

MetaClientConfig

public MetaClientConfig()

方法详细信息

getRecoverThreadCount

public int getRecoverThreadCount()

setRecoverThreadCount

public void setRecoverThreadCount(int recoverThreadCount)

getRecoverMessageIntervalInMills

public long getRecoverMessageIntervalInMills()

setRecoverMessageIntervalInMills

public void setRecoverMessageIntervalInMills(long recoverMessageIntervalInMills)

getZkConfig

public ZkUtils.ZKConfig getZkConfig()

setZkConfig

public void setZkConfig(ZkUtils.ZKConfig zkConfig)

getZkRoot

public String getZkRoot()

setZkRoot

public void setZkRoot(String zkRoot)

isZkEnable

public boolean isZkEnable()

setZkEnable

public void setZkEnable(boolean zkEnable)

getZkConnect

public String getZkConnect()

setZkConnect

public void setZkConnect(String zkConnect)

getZkSessionTimeoutMs

public int getZkSessionTimeoutMs()

setZkSessionTimeoutMs

public void setZkSessionTimeoutMs(int zkSessionTimeoutMs)

getZkConnectionTimeoutMs

public int getZkConnectionTimeoutMs()

setZkConnectionTimeoutMs

public void setZkConnectionTimeoutMs(int zkConnectionTimeoutMs)

getZkSyncTimeMs

public int getZkSyncTimeMs()

setZkSyncTimeMs

public void setZkSyncTimeMs(int zkSyncTimeMs)

getServerUrl

public String getServerUrl()

setServerUrl

public void setServerUrl(String serverUrl)

getDiamondPartitionsDataId

public String getDiamondPartitionsDataId()

getDiamondPartitionsGroup

public String getDiamondPartitionsGroup()

setPartitionsInfo

public void setPartitionsInfo(Properties partitionsInfo)

设置topic的分布情况. 对于使用严格顺序发送消息有效(OrderedMessageProducer),目前版本没有diamond所以从这里设置和获取。
partitionsInfo .put("topic.num.exampleTopic1","brokerId1:分区个数;brokerId2:分区个数...")
partitionsInfo .put("topic.num.exampleTopic2","brokerId1:分区个数;brokerId2:分区个数...")

参数：

partitionsInfo -

getPartitionsInfo

public Properties getPartitionsInfo()

hashCode

public int hashCode()

覆盖：

类 Object 中的 hashCode

equals

public boolean equals(Object obj)

覆盖：

类 Object 中的 equals