com.taobao.metamorphosis.client.extension
类 MetaBroadcastMessageSessionFactory

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

所有已实现的接口：

BroadcastMessageSessionFactory, MessageSessionFactory, Shutdownable

直接已知子类：

ExtMetaMessageSessionFactory

public class MetaBroadcastMessageSessionFactory
extends MetaMessageSessionFactory
implements BroadcastMessageSessionFactory

广播消息会话工厂,使用这个创建的Consumer在同一分组内的每台机器都能收到同一条消息, 推荐一个应用只使用一个MessageSessionFactory

从以下版本开始：

2011-6-13 下午02:44:24

作者：

无花

字段摘要

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

MAX_SCHEDULE_WRITTEN_BYTES, metaZookeeper, producerZooKeeper, remotingClient, sessionIdGenerator, TCP_NO_DELAY

构造方法摘要

MetaBroadcastMessageSessionFactory(MetaClientConfig metaClientConfig)

方法摘要

MessageConsumer	createBroadcastConsumer(ConsumerConfig consumerConfig) 创建广播方式接收的消息消费者，offset将存储在本地
protected MessageConsumer	createBroadcastConsumer(ConsumerConfig consumerConfig, RecoverManager recoverManager)

从类 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.MessageSessionFactory 继承的方法

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

构造方法详细信息

MetaBroadcastMessageSessionFactory

public MetaBroadcastMessageSessionFactory(MetaClientConfig metaClientConfig)
                                   throws MetaClientException

抛出：

MetaClientException

方法详细信息

createBroadcastConsumer

public MessageConsumer createBroadcastConsumer(ConsumerConfig consumerConfig)

从接口 BroadcastMessageSessionFactory 复制的描述

创建广播方式接收的消息消费者，offset将存储在本地

指定者：

接口 BroadcastMessageSessionFactory 中的 createBroadcastConsumer

参数：

consumerConfig - 消费者配置

返回：

createBroadcastConsumer

protected MessageConsumer createBroadcastConsumer(ConsumerConfig consumerConfig,
                                                  RecoverManager recoverManager)