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

所有超级接口：

MessageSessionFactory, Shutdownable

所有已知实现类：

AsyncMetaMessageSessionFactory

public interface AsyncMessageSessionFactory
extends MessageSessionFactory

 用于创建异步单向发送消息的会话工厂. 
 
 使用场景: 
      对于发送可靠性要求不那么高,但要求提高发送效率和降低对宿主应用的影响，提高宿主应用的稳定性.
      例如,收集日志或用户行为信息等场景.
 注意:
      发送消息后返回的结果中不包含准确的messageId,partition,offset,这些值都是-1




从以下版本开始：
  
2011-10-21 下午2:28:26
 

作者：

无花

方法摘要

AsyncMessageProducer	createAsyncProducer() 创建异步单向的消息生产者
AsyncMessageProducer	createAsyncProducer(PartitionSelector partitionSelector) 创建异步单向的消息生产者
AsyncMessageProducer	createAsyncProducer(PartitionSelector partitionSelector, AsyncMessageProducer.IgnoreMessageProcessor processor) 创建异步单向的消息生产者
AsyncMessageProducer	createAsyncProducer(PartitionSelector partitionSelector, int slidingWindowSize) 创建异步单向的消息生产者

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

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

方法详细信息

createAsyncProducer

AsyncMessageProducer createAsyncProducer()

创建异步单向的消息生产者

返回：

createAsyncProducer

AsyncMessageProducer createAsyncProducer(PartitionSelector partitionSelector)

创建异步单向的消息生产者

参数：

partitionSelector - 分区选择器

返回：

createAsyncProducer

AsyncMessageProducer createAsyncProducer(PartitionSelector partitionSelector,
                                         int slidingWindowSize)

创建异步单向的消息生产者

参数：

partitionSelector - 分区选择器

slidingWindowSize - 控制发送流量的滑动窗口大小,4k数据占窗口的一个单位,参考值:窗口大小为20000比较合适. 小于0则用默认值20000. 窗口开得太大可能导致OOM风险

返回：

createAsyncProducer

AsyncMessageProducer createAsyncProducer(PartitionSelector partitionSelector,
                                         AsyncMessageProducer.IgnoreMessageProcessor processor)

创建异步单向的消息生产者

参数：

partitionSelector - 分区选择器

slidingWindowSize - 控制发送流量的滑动窗口大小,4k数据占窗口的一个单位,参考值:窗口大小为20000比较合适. 小于0则用默认值20000. 窗口开得太大可能导致OOM风险

processor - 设置发送失败和超过流控消息的处理器,用户可以自己接管这些消息如何处理

返回：