com.taobao.metamorphosis.client.consumer
类 SubscribeInfoManager

java.lang.Object
  com.taobao.metamorphosis.client.consumer.SubscribeInfoManager

public class SubscribeInfoManager
extends Object

订阅信息管理器

构造方法摘要

SubscribeInfoManager()

方法摘要

MessageListener	getMessageListener(String topic, String group)
void	removeGroup(String group)
void	subscribe(String topic, String group, int maxSize, MessageListener messageListener, ConsumerMessageFilter consumerMessageFilter)

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

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

构造方法详细信息

SubscribeInfoManager

public SubscribeInfoManager()

方法详细信息

subscribe

public void subscribe(String topic,
                      String group,
                      int maxSize,
                      MessageListener messageListener,
                      ConsumerMessageFilter consumerMessageFilter)
               throws MetaClientException

抛出：

MetaClientException

getMessageListener

public MessageListener getMessageListener(String topic,
                                          String group)
                                   throws MetaClientException

抛出：

MetaClientException

removeGroup

public void removeGroup(String group)