com.taobao.metamorphosis.client.extension.producer
接口 AsyncMessageProducer

所有超级接口：

MessageProducer, Shutdownable

所有已知实现类：

AsyncMetaMessageProducer

public interface AsyncMessageProducer
extends MessageProducer

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




从以下版本开始：
  
2011-10-21 下午1:42:55
 

作者：

无花

嵌套类摘要

static interface

AsyncMessageProducer.IgnoreMessageProcessor 用于处理发送失败和超出流控的消息

方法摘要

void	asyncSendMessage(Message message) 异步发送消息.
void	asyncSendMessage(Message message, long timeout, TimeUnit unit) 异步发送消息.
void	setIgnoreMessageProcessor(AsyncMessageProducer.IgnoreMessageProcessor ignoreMessageProcessor) 设置发送失败和超过流控消息的处理器,用户可以自己接管这些消息如何处理

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

beginTransaction, commit, getPartitionSelector, getTransactionTimeout, isOrdered, publish, rollback, sendMessage, sendMessage, sendMessage, sendMessage, setDefaultTopic, setTransactionRequestTimeout, setTransactionTimeout, shutdown

方法详细信息

asyncSendMessage

void asyncSendMessage(Message message)

 异步发送消息.
 最大限度的减少对业务主流程的影响,使用者不关心发送成功或失败和所有异常





参数：
message - 

asyncSendMessage

void asyncSendMessage(Message message,
                      long timeout,
                      TimeUnit unit)

 异步发送消息. 
 最大限度的减少对业务主流程的影响,使用者不关心发送成功或失败和所有异常





参数：
message - 
timeout - 
unit - 

setIgnoreMessageProcessor

void setIgnoreMessageProcessor(AsyncMessageProducer.IgnoreMessageProcessor ignoreMessageProcessor)

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

参数：

ignoreMessageProcessor -