接口 com.taobao.metamorphosis.client.extension.producer.AsyncMessageProducer
的使用

使用 AsyncMessageProducer 的软件包
com.taobao.metamorphosis.client.extension   
com.taobao.metamorphosis.client.extension.log4j   
com.taobao.metamorphosis.client.extension.producer   
 

com.taobao.metamorphosis.client.extensionAsyncMessageProducer 的使用
 

返回 AsyncMessageProducercom.taobao.metamorphosis.client.extension 中的方法
 AsyncMessageProducer AsyncMetaMessageSessionFactory.createAsyncProducer()
           
 AsyncMessageProducer AsyncMessageSessionFactory.createAsyncProducer()
          创建异步单向的消息生产者
 AsyncMessageProducer AsyncMetaMessageSessionFactory.createAsyncProducer(PartitionSelector partitionSelector)
           
 AsyncMessageProducer AsyncMessageSessionFactory.createAsyncProducer(PartitionSelector partitionSelector)
          创建异步单向的消息生产者
 AsyncMessageProducer AsyncMetaMessageSessionFactory.createAsyncProducer(PartitionSelector partitionSelector, AsyncMessageProducer.IgnoreMessageProcessor processor)
           
 AsyncMessageProducer AsyncMessageSessionFactory.createAsyncProducer(PartitionSelector partitionSelector, AsyncMessageProducer.IgnoreMessageProcessor processor)
          创建异步单向的消息生产者
 AsyncMessageProducer AsyncMetaMessageSessionFactory.createAsyncProducer(PartitionSelector partitionSelector, int slidingWindowSize)
           
 AsyncMessageProducer AsyncMessageSessionFactory.createAsyncProducer(PartitionSelector partitionSelector, int slidingWindowSize)
          创建异步单向的消息生产者
 

com.taobao.metamorphosis.client.extension.log4jAsyncMessageProducer 的使用
 

声明为 AsyncMessageProducercom.taobao.metamorphosis.client.extension.log4j 中的字段
protected  AsyncMessageProducer StreamAppender.producer
           
 

com.taobao.metamorphosis.client.extension.producerAsyncMessageProducer 的使用
 

实现 AsyncMessageProducercom.taobao.metamorphosis.client.extension.producer 中的类
 class AsyncMetaMessageProducer
           异步单向发送消息给服务器的生产者实现.
 



Copyright © 2010–2013. All rights reserved.