com.alibaba.otter.common.push
类 AbstractSubscribeManager

java.lang.Object
  com.alibaba.otter.common.push.AbstractSubscribeManager

所有已实现的接口：

SubscribeManager

直接已知子类：

MediaSubscribeManager

public abstract class AbstractSubscribeManager
extends Object
implements SubscribeManager

帮助子类管理callback的manager

版本：

4.1.0

作者：

zebin.xuzb 2012-9-19 下午4:10:55

构造方法摘要

AbstractSubscribeManager()

方法摘要

protected abstract void	doInit()
protected abstract void	doShutdown()
protected void	doWhenCallbackEmpty(String dataId, String groupId, SubscribeCallback callback) 当同一个 dataId-groupId 的callback 被清楚完成之后的动作。
protected static String	generateKey(String dataId, String groupId)
protected Set<SubscribeCallback>	getCallbacks(String dataId)
protected Set<SubscribeCallback>	getCallbacks(String dataId, String groupId)
protected Object	getLock(String key)
protected Object	getLock(String dataId, String groupId)
void	init()
protected void	postRegisterCallback(String dataId, String groupId, SubscribeCallback callback) 注册监听器之后的方法，同于同一个 dataId-groupId，此方法不会并发
void	registerCallback(String dataId, String groupId, SubscribeCallback callback) 同 SubscribeManager.registerCallback(java.lang.String, com.alibaba.otter.common.push.SubscribeCallback)。
void	registerCallback(String dataId, SubscribeCallback callback) 注册监听dataId的callback，如果对应dataId的配置发生了变化，则回调callback。
void	shutdown()
void	unRegisterCallback(String dataId, String groupId, SubscribeCallback callback) 移除监听事件
void	unRegisterCallback(String dataId, SubscribeCallback callback) 移除监听事件

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

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

从接口 com.alibaba.otter.common.push.SubscribeManager 继承的方法

fetchConfig, fetchConfig, fetchConfig, fetchConfig

构造方法详细信息

AbstractSubscribeManager

public AbstractSubscribeManager()

方法详细信息

init

public void init()

指定者：

接口 SubscribeManager 中的 init

doInit

protected abstract void doInit()

shutdown

public void shutdown()

指定者：

接口 SubscribeManager 中的 shutdown

doShutdown

protected abstract void doShutdown()

registerCallback

public void registerCallback(String dataId,
                             SubscribeCallback callback)

从接口 SubscribeManager 复制的描述

注册监听dataId的callback，如果对应dataId的配置发生了变化，则回调callback。
callback 的处理逻辑应该尽可能的快，如果callback处理的时间需要很长，建议采取异步的方式进行处理
或者实现可以起一个线程池，帮助客户端吧callback做异步处理。

指定者：

接口 SubscribeManager 中的 registerCallback

registerCallback

public void registerCallback(String dataId,
                             String groupId,
                             SubscribeCallback callback)

从接口 SubscribeManager 复制的描述

同 SubscribeManager.registerCallback(java.lang.String, com.alibaba.otter.common.push.SubscribeCallback)。
groupId 也是组成配置key的部分，可以为null。

指定者：

接口 SubscribeManager 中的 registerCallback

unRegisterCallback

public void unRegisterCallback(String dataId,
                               SubscribeCallback callback)

从接口 SubscribeManager 复制的描述

移除监听事件

指定者：

接口 SubscribeManager 中的 unRegisterCallback

unRegisterCallback

public void unRegisterCallback(String dataId,
                               String groupId,
                               SubscribeCallback callback)

从接口 SubscribeManager 复制的描述

移除监听事件

指定者：

接口 SubscribeManager 中的 unRegisterCallback

doWhenCallbackEmpty

protected void doWhenCallbackEmpty(String dataId,
                                   String groupId,
                                   SubscribeCallback callback)

当同一个 dataId-groupId 的callback 被清楚完成之后的动作。同于同一个 dataId-groupId，此方法不会并发

参数：

dataId -

groupId -

callback -

postRegisterCallback

protected void postRegisterCallback(String dataId,
                                    String groupId,
                                    SubscribeCallback callback)

注册监听器之后的方法，同于同一个 dataId-groupId，此方法不会并发

参数：

dataId -

groupId -

callback -

getCallbacks

protected Set<SubscribeCallback> getCallbacks(String dataId)

getCallbacks

protected Set<SubscribeCallback> getCallbacks(String dataId,
                                              String groupId)

generateKey

protected static String generateKey(String dataId,
                                    String groupId)

getLock

protected Object getLock(String dataId,
                         String groupId)

getLock

protected Object getLock(String key)