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()

指定者:

init 在接口中 SubscribeManager

doInit

protected abstract void doInit()

shutdown

public void shutdown()

指定者:

shutdown 在接口中 SubscribeManager

doShutdown

protected abstract void doShutdown()

registerCallback

public void registerCallback(String dataId,
                             SubscribeCallback callback)

从接口复制的说明: SubscribeManager

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

指定者:

registerCallback 在接口中 SubscribeManager

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。

指定者:

registerCallback 在接口中 SubscribeManager

unRegisterCallback

public void unRegisterCallback(String dataId,
                               SubscribeCallback callback)

从接口复制的说明: SubscribeManager

移除监听事件

指定者:

unRegisterCallback 在接口中 SubscribeManager

unRegisterCallback

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

从接口复制的说明: SubscribeManager

移除监听事件

指定者:

unRegisterCallback 在接口中 SubscribeManager

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)