com.taobao.metamorphosis.metaslave
类 MetaSlaveListener

java.lang.Object
  com.taobao.metamorphosis.metaslave.MetaSlaveListener

所有已实现的接口：

MessageListener

public class MetaSlaveListener
extends Object
implements MessageListener

从以下版本开始：

2011-6-23 下午03:59:21

作者：

无花

构造方法摘要

MetaSlaveListener(BrokerZooKeeper brokerZooKeeper, MessageStoreManager storeManager, SlaveStatsManager slaveStatsManager)

方法摘要

Executor	getExecutor() 处理消息的线程池
void	recieveMessages(Message message) 接收到消息，只有messages不为空并且不为null的情况下会触发此方法

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

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

构造方法详细信息

MetaSlaveListener

public MetaSlaveListener(BrokerZooKeeper brokerZooKeeper,
                         MessageStoreManager storeManager,
                         SlaveStatsManager slaveStatsManager)

方法详细信息

getExecutor

public Executor getExecutor()

从接口 MessageListener 复制的描述

处理消息的线程池

指定者：

接口 MessageListener 中的 getExecutor

返回：

recieveMessages

public void recieveMessages(Message message)
                     throws InterruptedException

从接口 MessageListener 复制的描述

接收到消息，只有messages不为空并且不为null的情况下会触发此方法

指定者：

接口 MessageListener 中的 recieveMessages

抛出：

InterruptedException