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

使用 AsyncMessageProducer.IgnoreMessageProcessor 的软件包

com.taobao.metamorphosis.client.extension
com.taobao.metamorphosis.client.extension.producer

com.taobao.metamorphosis.client.extension 中 AsyncMessageProducer.IgnoreMessageProcessor 的使用

参数类型为 AsyncMessageProducer.IgnoreMessageProcessor 的 com.taobao.metamorphosis.client.extension 中的方法

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

com.taobao.metamorphosis.client.extension.producer 中 AsyncMessageProducer.IgnoreMessageProcessor 的使用

参数类型为 AsyncMessageProducer.IgnoreMessageProcessor 的 com.taobao.metamorphosis.client.extension.producer 中的方法

void	AsyncMetaMessageProducer.setIgnoreMessageProcessor(AsyncMessageProducer.IgnoreMessageProcessor ignoreMessageProcessor)
void	AsyncMessageProducer.setIgnoreMessageProcessor(AsyncMessageProducer.IgnoreMessageProcessor ignoreMessageProcessor) 设置发送失败和超过流控消息的处理器,用户可以自己接管这些消息如何处理

参数类型为 AsyncMessageProducer.IgnoreMessageProcessor 的 com.taobao.metamorphosis.client.extension.producer 中的构造方法

AsyncMetaMessageProducer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, PartitionSelector partitionSelector, ProducerZooKeeper producerZooKeeper, String sessionId, int slidingWindowSize0, AsyncMessageProducer.IgnoreMessageProcessor processor)