com.taobao.metamorphosis.client.extension
类 AsyncMetaMessageSessionFactory

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

所有已实现的接口：

AsyncMessageSessionFactory, MessageSessionFactory, Shutdownable

public class AsyncMetaMessageSessionFactory
extends MetaMessageSessionFactory
implements AsyncMessageSessionFactory

用于创建异步单向发送消息的会话工厂.

从以下版本开始：

2011-10-21 下午2:29:55

作者：

无花

字段摘要

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

MAX_SCHEDULE_WRITTEN_BYTES, metaZookeeper, producerZooKeeper, remotingClient, sessionIdGenerator, TCP_NO_DELAY

构造方法摘要

AsyncMetaMessageSessionFactory(MetaClientConfig metaClientConfig)

方法摘要

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

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

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

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

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

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

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

构造方法详细信息

AsyncMetaMessageSessionFactory

public AsyncMetaMessageSessionFactory(MetaClientConfig metaClientConfig)
                               throws MetaClientException

抛出：

MetaClientException

方法详细信息

createAsyncProducer

public AsyncMessageProducer createAsyncProducer()

从接口 AsyncMessageSessionFactory 复制的描述

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

指定者：

接口 AsyncMessageSessionFactory 中的 createAsyncProducer

返回：

createAsyncProducer

public AsyncMessageProducer createAsyncProducer(PartitionSelector partitionSelector)

从接口 AsyncMessageSessionFactory 复制的描述

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

指定者：

接口 AsyncMessageSessionFactory 中的 createAsyncProducer

参数：

partitionSelector - 分区选择器

返回：

createAsyncProducer

public AsyncMessageProducer createAsyncProducer(PartitionSelector partitionSelector,
                                                int slidingWindowSize)

从接口 AsyncMessageSessionFactory 复制的描述

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

指定者：

接口 AsyncMessageSessionFactory 中的 createAsyncProducer

参数：

partitionSelector - 分区选择器

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

返回：

createAsyncProducer

public AsyncMessageProducer createAsyncProducer(PartitionSelector partitionSelector,
                                                AsyncMessageProducer.IgnoreMessageProcessor processor)

从接口 AsyncMessageSessionFactory 复制的描述

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

指定者：

接口 AsyncMessageSessionFactory 中的 createAsyncProducer

参数：

partitionSelector - 分区选择器

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

返回：