com.taobao.metamorphosis.client.extension
接口 ExtMessageSessionFactory

所有超级接口：

BroadcastMessageSessionFactory, MessageSessionFactory, Shutdownable

所有已知实现类：

ExtMetaMessageSessionFactory

public interface ExtMessageSessionFactory
extends BroadcastMessageSessionFactory

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

从以下版本开始：

2011-11-7 下午4:06:15

作者：

无花

方法摘要

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.BroadcastMessageSessionFactory 继承的方法

createBroadcastConsumer

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

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

方法详细信息

createConsumer

MessageConsumer createConsumer(ConsumerConfig consumerConfig,
                               ConsumerRecoverType RecoverType)

创建消费者

参数：

consumerConfig - 消费者配置

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

返回：

createConsumer

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

创建消费者

参数：

consumerConfig - 消费者配置

offsetStorage - offset存储器

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

返回：

createBroadcastConsumer

MessageConsumer createBroadcastConsumer(ConsumerConfig consumerConfig,
                                        ConsumerRecoverType recoverType)

创建广播消费者

参数：

consumerConfig -

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

返回：