接口 com.taobao.metamorphosis.client.consumer.MessageConsumer
的使用

使用 MessageConsumer 的软件包

com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.client.extension
com.taobao.metamorphosis.client.extension.spring

com.taobao.metamorphosis.client 中 MessageConsumer 的使用

返回 MessageConsumer 的 com.taobao.metamorphosis.client 中的方法

MessageConsumer	MetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig)
MessageConsumer	MessageSessionFactory.createConsumer(ConsumerConfig consumerConfig) 创建消息消费者，默认将offset存储在zk
MessageConsumer	MetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage)
MessageConsumer	MessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage) 创建消息消费者，使用指定的offset存储器
protected MessageConsumer	MetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, RecoverManager recoverManager0)
MessageConsumer	MetaTopicBrowser.getConsumer()

参数类型为 MessageConsumer 的 com.taobao.metamorphosis.client 中的构造方法

MetaTopicBrowser(String topic, int maxSize, long timeoutInMills, MessageConsumer consumer, List<Partition> partitions)

com.taobao.metamorphosis.client.consumer 中 MessageConsumer 的使用

实现 MessageConsumer 的 com.taobao.metamorphosis.client.consumer 中的类

class

SimpleMessageConsumer 消息消费者基类

返回 MessageConsumer 的 com.taobao.metamorphosis.client.consumer 中的方法

MessageConsumer	SimpleMessageConsumer.subscribe(String topic, int maxSize, MessageListener messageListener)
MessageConsumer	MessageConsumer.subscribe(String topic, int maxSize, MessageListener messageListener) 订阅指定的消息，传入MessageListener，当有消息达到的时候主动通知MessageListener，请注意， 调用此方法并不会使订阅关系立即生效， 只有在调用complete方法后才生效，此方法可做链式调用
MessageConsumer	SimpleMessageConsumer.subscribe(String topic, int maxSize, MessageListener messageListener, ConsumerMessageFilter filter)
MessageConsumer	MessageConsumer.subscribe(String topic, int maxSize, MessageListener messageListener, ConsumerMessageFilter consumerMessageFilter) 订阅指定的消息，传入MessageListener和ConsumerMessageFilter， 当有消息到达并且ConsumerMessageFilter #accept返回true的时候,主动通知MessageListener该条消息，请注意， 调用此方法并不会使订阅关系立即生效， 只有在调用complete方法后才生效，此方法可做链式调用

参数类型为 MessageConsumer 的 com.taobao.metamorphosis.client.consumer 中的方法

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

com.taobao.metamorphosis.client.extension 中 MessageConsumer 的使用

返回 MessageConsumer 的 com.taobao.metamorphosis.client.extension 中的方法

MessageConsumer	MetaBroadcastMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig)
MessageConsumer	BroadcastMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig) 创建广播方式接收的消息消费者，offset将存储在本地
MessageConsumer	ExtMetaMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType)
MessageConsumer	ExtMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType) 创建广播消费者
protected MessageConsumer	MetaBroadcastMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig, RecoverManager recoverManager)
MessageConsumer	OrderedMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig)
MessageConsumer	ExtMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType)
MessageConsumer	ExtMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType RecoverType) 创建消费者
MessageConsumer	OrderedMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage)
MessageConsumer	ExtMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConsumerRecoverType recoverType)
MessageConsumer	ExtMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConsumerRecoverType recoverType) 创建消费者

com.taobao.metamorphosis.client.extension.spring 中 MessageConsumer 的使用

类型参数类型为 MessageConsumer 的 com.taobao.metamorphosis.client.extension.spring 中的字段

protected CopyOnWriteArraySet<MessageConsumer>

MessageListenerContainer.consumers

返回 MessageConsumer 的 com.taobao.metamorphosis.client.extension.spring 中的方法

protected MessageConsumer

MessageListenerContainer.getMessageConsumer(MetaqTopic topic)