com.taobao.metamorphosis.client.extension
类 ExtMetaMessageSessionFactory

java.lang.Object
  com.taobao.metamorphosis.client.MetaMessageSessionFactory
      com.taobao.metamorphosis.client.extension.MetaBroadcastMessageSessionFactory
          com.taobao.metamorphosis.client.extension.ExtMetaMessageSessionFactory

所有已实现的接口：

BroadcastMessageSessionFactory, ExtMessageSessionFactory, MessageSessionFactory, Shutdownable

public class ExtMetaMessageSessionFactory
extends MetaBroadcastMessageSessionFactory
implements ExtMessageSessionFactory

一个扩展的Meta会话工厂,提供一些扩展功能.

从以下版本开始：

2011-11-7 下午4:09:56

作者：

无花

字段摘要

从类 com.taobao.metamorphosis.client.MetaMessageSessionFactory 继承的字段

MAX_SCHEDULE_WRITTEN_BYTES, metaZookeeper, producerZooKeeper, remotingClient, sessionIdGenerator, TCP_NO_DELAY

构造方法摘要

ExtMetaMessageSessionFactory(MetaClientConfig metaClientConfig)

方法摘要

MessageConsumer	createBroadcastConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType) 创建广播消费者
MessageConsumer	createConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType) 创建消费者
MessageConsumer	createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConsumerRecoverType recoverType) 创建消费者

从类 com.taobao.metamorphosis.client.extension.MetaBroadcastMessageSessionFactory 继承的方法

createBroadcastConsumer, createBroadcastConsumer

从类 com.taobao.metamorphosis.client.MetaMessageSessionFactory 继承的方法

addChild, checkConsumerConfig, createConsumer, createConsumer, createConsumer, createLoadBalanceStrategy, createProducer, createProducer, createProducer, createProducer, createTopicBrowser, createTopicBrowser, getChildren, getConsumerZooKeeper, getMetaClientConfig, getPartitionsForTopic, getProducerZooKeeper, getRecoverStorageManager, getRemotingClient, getStats, getStats, getStats, getStats, getSubscribeInfoManager, initConsumerZooKeeper, removeChild, shutdown

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

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

从接口 com.taobao.metamorphosis.client.extension.BroadcastMessageSessionFactory 继承的方法

createBroadcastConsumer

从接口 com.taobao.metamorphosis.client.MessageSessionFactory 继承的方法

createConsumer, createConsumer, createProducer, createProducer, createProducer, createProducer, createTopicBrowser, createTopicBrowser, getPartitionsForTopic, getStats, getStats, getStats, getStats, shutdown

构造方法详细信息

ExtMetaMessageSessionFactory

public ExtMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
                             throws MetaClientException

抛出：

MetaClientException

方法详细信息

createConsumer

public MessageConsumer createConsumer(ConsumerConfig consumerConfig,
                                      ConsumerRecoverType recoverType)

从接口 ExtMessageSessionFactory 复制的描述

创建消费者

指定者：

接口 ExtMessageSessionFactory 中的 createConsumer

参数：

consumerConfig - 消费者配置

recoverType - 选择消息recover方式, ConsumerRecoverType.DEFAULT,ConsumerRecoverType.NOTIFY
目前不支持ConsumerRecoverType.NOTIFY

返回：

createConsumer

public MessageConsumer createConsumer(ConsumerConfig consumerConfig,
                                      OffsetStorage offsetStorage,
                                      ConsumerRecoverType recoverType)

从接口 ExtMessageSessionFactory 复制的描述

创建消费者

指定者：

接口 ExtMessageSessionFactory 中的 createConsumer

参数：

consumerConfig - 消费者配置

offsetStorage - offset存储器

返回：

createBroadcastConsumer

public MessageConsumer createBroadcastConsumer(ConsumerConfig consumerConfig,
                                               ConsumerRecoverType recoverType)

从接口 ExtMessageSessionFactory 复制的描述

创建广播消费者

指定者：

接口 ExtMessageSessionFactory 中的 createBroadcastConsumer

返回：