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

所有超级接口:
MessageSessionFactory, Shutdownable
所有已知子接口:
ExtMessageSessionFactory
所有已知实现类:
ExtMetaMessageSessionFactory, MetaBroadcastMessageSessionFactory

public interface BroadcastMessageSessionFactory
extends MessageSessionFactory

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

从以下版本开始:
2011-6-13 下午02:49:27
作者:
无花

方法摘要
 MessageConsumer createBroadcastConsumer(ConsumerConfig consumerConfig)
          创建广播方式接收的消息消费者,offset将存储在本地
 
从接口 com.taobao.metamorphosis.client.MessageSessionFactory 继承的方法
createConsumer, createConsumer, createProducer, createProducer, createProducer, createProducer, createTopicBrowser, createTopicBrowser, getPartitionsForTopic, getStats, getStats, getStats, getStats, shutdown
 

方法详细信息

createBroadcastConsumer

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

参数:
consumerConfig - 消费者配置
返回:


Copyright © 2010–2013. All rights reserved.