com.taobao.metamorphosis.client.extension.spring
类 AbstractMetaqMessageSessionFactory<T extends MessageSessionFactory>

java.lang.Object
  com.taobao.metamorphosis.client.extension.spring.AbstractMetaqMessageSessionFactory<T>

类型参数：

T -

所有已实现的接口：

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean

直接已知子类：

MetaqMessageSessionFactoryBean, XAMetaqMessageSessionFactoryBean

public abstract class AbstractMetaqMessageSessionFactory<T extends MessageSessionFactory>
extends Object
implements org.springframework.beans.factory.FactoryBean, org.springframework.beans.factory.DisposableBean

Base factory bean class to create message sessionfactory.

从以下版本开始：

1.4.5

作者：

dennis

字段摘要

protected MetaClientConfig	metaClientConfig
protected T	sessionFactory

构造方法摘要

AbstractMetaqMessageSessionFactory()

方法摘要

void	destroy()
MetaClientConfig	getMetaClientConfig()
Properties	getPartitionsInfo()
long	getRecoverMessageIntervalInMills()
int	getRecoverThreadCount()
String	getServerUrl()
ZkUtils.ZKConfig	getZkConfig()
String	getZkConnect()
int	getZkConnectionTimeoutMs()
String	getZkRoot()
int	getZkSessionTimeoutMs()
int	getZkSyncTimeMs()
boolean	isSingleton()
boolean	isZkEnable()
void	setMetaClientConfig(MetaClientConfig metaClientConfig)
void	setPartitionsInfo(Properties partitionsInfo)
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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口 org.springframework.beans.factory.FactoryBean 继承的方法

getObject, getObjectType

字段详细信息

metaClientConfig

protected MetaClientConfig metaClientConfig

sessionFactory

protected T extends MessageSessionFactory sessionFactory

构造方法详细信息

AbstractMetaqMessageSessionFactory

public AbstractMetaqMessageSessionFactory()

方法详细信息

destroy

public void destroy()
             throws Exception

指定者：

接口 org.springframework.beans.factory.DisposableBean 中的 destroy

抛出：

Exception

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)

getServerUrl

public String getServerUrl()

setServerUrl

public void setServerUrl(String serverUrl)

setPartitionsInfo

public void setPartitionsInfo(Properties partitionsInfo)

getPartitionsInfo

public Properties getPartitionsInfo()

getMetaClientConfig

public MetaClientConfig getMetaClientConfig()

setMetaClientConfig

public void setMetaClientConfig(MetaClientConfig metaClientConfig)

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)

isSingleton

public boolean isSingleton()

指定者：

接口 org.springframework.beans.factory.FactoryBean 中的 isSingleton