cn.weforward.data.persister.support

类 TopicWather

java.lang.Object

cn.weforward.data.persister.support.AbstractWather

cn.weforward.data.persister.support.TopicWather

所有已实现的接口:

Watcher, cn.weforward.protocol.topic.TopicListener<Revision>

public class TopicWather
extends AbstractWather
implements cn.weforward.protocol.topic.TopicListener<Revision>

通过weforward的topic消息框架进行存储项变化通知

作者:

liangcha

嵌套类概要

从接口继承的嵌套类/接口 cn.weforward.data.persister.ext.Watcher

Watcher.Listener

字段概要

字段

限定符和类型	字段和说明
protected cn.weforward.protocol.topic.TopicProducer	m_Producer
protected String	m_Topic

从类继承的字段 cn.weforward.data.persister.support.AbstractWather

_Logger, m_Listeners

构造器概要

构造器

构造器和说明
TopicWather(String schemaName)

方法概要

限定符和类型	方法和说明
String	getTopic()
void	onReceive(cn.weforward.protocol.topic.Topic topic, Revision content)
void	publish(String tag, Revision revision) 发布变化版本信息
void	setProducer(cn.weforward.protocol.topic.TopicProducer producer)
void	setTopic(String topic)
void	setTopicHub(cn.weforward.protocol.topic.TopicHub hub)

从类继承的方法 cn.weforward.data.persister.support.AbstractWather

fireChange, getListeners, register, suspend, unregister, wakeup

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

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

字段详细资料

m_Topic

protected String m_Topic

m_Producer

protected cn.weforward.protocol.topic.TopicProducer m_Producer

构造器详细资料

TopicWather

public TopicWather(String schemaName)

方法详细资料

setTopic

public void setTopic(String topic)

setProducer

public void setProducer(cn.weforward.protocol.topic.TopicProducer producer)

setTopicHub

public void setTopicHub(cn.weforward.protocol.topic.TopicHub hub)

getTopic

public String getTopic()

指定者:

getTopic 在接口中 cn.weforward.protocol.topic.TopicListener<Revision>

onReceive

public void onReceive(cn.weforward.protocol.topic.Topic topic,
                      Revision content)

指定者:

onReceive 在接口中 cn.weforward.protocol.topic.TopicListener<Revision>

publish

public void publish(String tag,
                    Revision revision)

从接口复制的说明: Watcher

发布变化版本信息

指定者:

publish 在接口中 Watcher

参数:

tag - 标签（表名/对象名）

revision - 变化的版本信息