com.taobao.metamorphosis.client.consumer
类 SimpleMessageConsumer.LocalRecoverPolicy

java.lang.Object
  com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer.LocalRecoverPolicy

所有已实现的接口：

RejectConsumptionHandler

包容类：

SimpleMessageConsumer

public static class SimpleMessageConsumer.LocalRecoverPolicy
extends Object
implements RejectConsumptionHandler

Created with IntelliJ IDEA. User: dennis (xzhuang@avos.com) Date: 13-2-5 Time: 上午11:25

构造方法摘要

SimpleMessageConsumer.LocalRecoverPolicy(RecoverManager recoverManager)

方法摘要

void	rejectConsumption(Message message, MessageConsumer messageConsumer) Method that may be invoked by a MessageConsumer when receiveMessages cannot process a message when retry too many times.

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

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

构造方法详细信息

SimpleMessageConsumer.LocalRecoverPolicy

public SimpleMessageConsumer.LocalRecoverPolicy(RecoverManager recoverManager)

方法详细信息

rejectConsumption

public void rejectConsumption(Message message,
                              MessageConsumer messageConsumer)

从接口 RejectConsumptionHandler 复制的描述

Method that may be invoked by a MessageConsumer when receiveMessages cannot process a message when retry too many times.

指定者：

接口 RejectConsumptionHandler 中的 rejectConsumption