|
||||||||||
| 上一个 下一个 | 框架 无框架 | |||||||||
| com.taobao.metamorphosis.client 中 MetaClientConfig 的使用 |
|---|
| 返回 MetaClientConfig 的 com.taobao.metamorphosis.client 中的方法 | |
|---|---|
MetaClientConfig |
MetaMessageSessionFactory.getMetaClientConfig()
返回客户端配置 |
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client 中的构造方法 | |
|---|---|
MetaMessageSessionFactory(MetaClientConfig metaClientConfig)
|
|
XAMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
|
|
| com.taobao.metamorphosis.client.consumer 中 MetaClientConfig 的使用 |
|---|
| com.taobao.metamorphosis.client.consumer 中 MetaClientConfig 的子类 | |
|---|---|
class |
ConsumerConfig
消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。 |
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client.consumer 中的方法 | |
|---|---|
void |
RecoverStorageManager.start(MetaClientConfig metaClientConfig)
|
void |
RecoverManager.start(MetaClientConfig metaClientConfig)
启动recover |
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client.consumer 中的构造方法 | |
|---|---|
RecoverStorageManager(MetaClientConfig metaClientConfig,
SubscribeInfoManager subscribeInfoManager)
|
|
| com.taobao.metamorphosis.client.extension 中 MetaClientConfig 的使用 |
|---|
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client.extension 中的构造方法 | |
|---|---|
AsyncMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
|
|
ExtMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
|
|
MetaBroadcastMessageSessionFactory(MetaClientConfig metaClientConfig)
|
|
OrderedMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
|
|
| com.taobao.metamorphosis.client.extension.consumer 中 MetaClientConfig 的使用 |
|---|
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client.extension.consumer 中的方法 | |
|---|---|
void |
RecoverNotifyManager.start(MetaClientConfig metaClientConfig)
|
| com.taobao.metamorphosis.client.extension.producer 中 MetaClientConfig 的使用 |
|---|
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client.extension.producer 中的构造方法 | |
|---|---|
LocalMessageStorageManager(MetaClientConfig metaClientConfig)
|
|
LocalMessageStorageManager(MetaClientConfig metaClientConfig,
String path,
MessageRecoverManager.MessageRecoverer messageRecoverer)
|
|
OrderedLocalMessageStorageManager(MetaClientConfig metaClientConfig)
|
|
ProducerDiamondManager(MetaClientConfig metaClientConfig)
|
|
| com.taobao.metamorphosis.client.extension.spring 中 MetaClientConfig 的使用 |
|---|
| 声明为 MetaClientConfig 的 com.taobao.metamorphosis.client.extension.spring 中的字段 | |
|---|---|
protected MetaClientConfig |
AbstractMetaqMessageSessionFactory.metaClientConfig
|
| 返回 MetaClientConfig 的 com.taobao.metamorphosis.client.extension.spring 中的方法 | |
|---|---|
MetaClientConfig |
AbstractMetaqMessageSessionFactory.getMetaClientConfig()
|
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client.extension.spring 中的方法 | |
|---|---|
void |
AbstractMetaqMessageSessionFactory.setMetaClientConfig(MetaClientConfig metaClientConfig)
|
| com.taobao.metamorphosis.client.producer 中 MetaClientConfig 的使用 |
|---|
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.client.producer 中的构造方法 | |
|---|---|
ProducerZooKeeper(MetaZookeeper metaZookeeper,
RemotingClientWrapper remotingClient,
org.I0Itec.zkclient.ZkClient zkClient,
MetaClientConfig metaClientConfig)
|
|
| com.taobao.metamorphosis.metaslave 中 MetaClientConfig 的使用 |
|---|
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.metaslave 中的方法 | |
|---|---|
static SlaveMetaMessageSessionFactory |
SlaveMetaMessageSessionFactory.create(MetaClientConfig metaClientConfig,
int brokerId)
|
| com.taobao.metamorphosis.storm.spout 中 MetaClientConfig 的使用 |
|---|
| 参数类型为 MetaClientConfig 的 com.taobao.metamorphosis.storm.spout 中的构造方法 | |
|---|---|
MetaSpout(MetaClientConfig metaClientConfig,
ConsumerConfig consumerConfig,
backtype.storm.spout.Scheme scheme)
|
|
| com.taobao.metamorphosis.tools.monitor.core 中 MetaClientConfig 的使用 |
|---|
| 返回 MetaClientConfig 的 com.taobao.metamorphosis.tools.monitor.core 中的方法 | |
|---|---|
MetaClientConfig |
MonitorConfig.metaClientConfigOf(String serverUrl)
|
|
||||||||||
| 上一个 下一个 | 框架 无框架 | |||||||||