com.taobao.metamorphosis.client.extension
接口 BroadcastMessageSessionFactory
- 所有超级接口:
- MessageSessionFactory, Shutdownable
- 所有已知子接口:
- ExtMessageSessionFactory
- 所有已知实现类:
- ExtMetaMessageSessionFactory, MetaBroadcastMessageSessionFactory
public interface BroadcastMessageSessionFactory
- extends MessageSessionFactory
广播消息会话工厂,使用这个创建的Consumer在同一分组内的每台机器都能收到同一条消息,
推荐一个应用只使用一个MessageSessionFactory
- 从以下版本开始:
- 2011-6-13 下午02:49:27
- 作者:
- 无花
从接口 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.