com.taobao.metamorphosis.client.extension
类 OrderedMetaMessageSessionFactory

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

所有已实现的接口：

OrderedMessageSessionFactory, MessageSessionFactory, Shutdownable

public class OrderedMetaMessageSessionFactory
extends MetaMessageSessionFactory
implements OrderedMessageSessionFactory

 消息会话工厂，meta客户端的主接口,推荐一个应用只使用一个.
 需要按照消息内容(例如某个id)散列到固定分区并要求有序的场景中使用.
 

从以下版本开始：

2011-8-24 下午4:31:45

作者：

无花

字段摘要

protected MessageRecoverManager	localMessageStorageManager
protected ProducerDiamondManager	producerDiamondManager

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

MAX_SCHEDULE_WRITTEN_BYTES, metaZookeeper, producerZooKeeper, remotingClient, sessionIdGenerator, TCP_NO_DELAY

构造方法摘要

OrderedMetaMessageSessionFactory(MetaClientConfig metaClientConfig)

方法摘要

MessageConsumer	createConsumer(ConsumerConfig consumerConfig) 创建消息消费者，默认将offset存储在zk
MessageConsumer	createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage) 创建消息消费者，使用指定的offset存储器
MessageProducer	createProducer() 创建消息生产者，默认使用轮询分区选择器
MessageProducer	createProducer(boolean ordered) 创建消息生产者，默认使用轮询分区选择器。
MessageProducer	createProducer(PartitionSelector partitionSelector) 创建消息生产者
MessageProducer	createProducer(PartitionSelector partitionSelector, boolean ordered) 创建消息生产者
void	shutdown() 关闭工厂

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

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

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

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

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

createTopicBrowser, createTopicBrowser, getPartitionsForTopic, getStats, getStats, getStats, getStats

字段详细信息

localMessageStorageManager

protected final MessageRecoverManager localMessageStorageManager

producerDiamondManager

protected final ProducerDiamondManager producerDiamondManager

构造方法详细信息

OrderedMetaMessageSessionFactory

public OrderedMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
                                 throws MetaClientException

抛出：

MetaClientException

方法详细信息

shutdown

public void shutdown()
              throws MetaClientException

从接口 MessageSessionFactory 复制的描述

关闭工厂

指定者：

接口 MessageSessionFactory 中的 shutdown

指定者：

接口 Shutdownable 中的 shutdown

覆盖：

类 MetaMessageSessionFactory 中的 shutdown

抛出：

MetaClientException

createProducer

public MessageProducer createProducer(PartitionSelector partitionSelector)

创建消息生产者

指定者：

接口 MessageSessionFactory 中的 createProducer

覆盖：

类 MetaMessageSessionFactory 中的 createProducer

参数：

partitionSelector - 传入OrderedMessagePartitionSelector的继承类可支持消息散列到固定分区、可靠发送和顺序特性

返回：

createProducer

public MessageProducer createProducer()

从接口 MessageSessionFactory 复制的描述

创建消息生产者，默认使用轮询分区选择器

指定者：

接口 MessageSessionFactory 中的 createProducer

覆盖：

类 MetaMessageSessionFactory 中的 createProducer

返回：

createProducer

public MessageProducer createProducer(boolean ordered)

从接口 MessageSessionFactory 复制的描述

创建消息生产者，默认使用轮询分区选择器。本方法已经废弃，请勿使用，不排除在未来某个版本删除。

指定者：

接口 MessageSessionFactory 中的 createProducer

覆盖：

类 MetaMessageSessionFactory 中的 createProducer

参数：

ordered - 是否有序，true为有序，如果有序，则消息按照发送顺序保存在MQ server

返回：

createProducer

public MessageProducer createProducer(PartitionSelector partitionSelector,
                                      boolean ordered)

创建消息生产者

指定者：

接口 MessageSessionFactory 中的 createProducer

覆盖：

类 MetaMessageSessionFactory 中的 createProducer

参数：

partitionSelector - 传入OrderedMessagePartitionSelector的继承类可支持消息散列到固定分区、可靠发送和顺序特性

ordered - 是否需要多线程有序

返回：

createConsumer

public MessageConsumer createConsumer(ConsumerConfig consumerConfig)

从接口 MessageSessionFactory 复制的描述

创建消息消费者，默认将offset存储在zk

指定者：

接口 MessageSessionFactory 中的 createConsumer

覆盖：

类 MetaMessageSessionFactory 中的 createConsumer

参数：

consumerConfig - 消费者配置

返回：

createConsumer

public MessageConsumer createConsumer(ConsumerConfig consumerConfig,
                                      OffsetStorage offsetStorage)

从接口 MessageSessionFactory 复制的描述

创建消息消费者，使用指定的offset存储器

指定者：

接口 MessageSessionFactory 中的 createConsumer

覆盖：

类 MetaMessageSessionFactory 中的 createConsumer

参数：

consumerConfig - 消费者配置

offsetStorage - offset存储器

返回：