gu.sql2java.observer

类 RowObserver.TableObserverChannel

java.lang.Object

gu.simplemq.Channel<java.lang.String>

gu.sql2java.observer.RowObserver.TableObserverChannel

所有已实现的接口:

gu.simplemq.Constant, gu.simplemq.IMessageAdapter<java.lang.String>, java.lang.Cloneable

封闭类:

RowObserver

public static class RowObserver.TableObserverChannel
extends gu.simplemq.Channel<java.lang.String>

表侦听器频道实现

作者:

guyadong

字段概要

从类继承的字段 gu.simplemq.Channel

name, type

从接口继承的字段 gu.simplemq.Constant

AMQP_SCHEMA, DEFAULT_AMQP_CONNECTOR, DEFAULT_AMQP_PORT, DEFAULT_CONSUMER_CHECK_INTERVAL, DEFAULT_KEY_SEPARATOR, DEFAULT_MQ_HOST, DEFAULT_MQTT_CONNECTOR, DEFAULT_MQTT_PORT, logger, MQ_CLIENTID, MQ_HOST, MQ_PASSWORD, MQ_PORT, MQ_PUBSUB_HOST, MQ_PUBSUB_MQTT, MQ_PUBSUB_PORT, MQ_PUBSUB_URI, MQ_QUEUE_HOST, MQ_QUEUE_PORT, MQ_QUEUE_URI, MQ_TIMEOUT, MQ_URI, MQ_USERNAME, MQ_WS_HOST, MQ_WS_PORT, MQ_WS_URI, MQTT_SCHEMA, PUBSUB_PREFIX, QUEUE_PREFIX, UTF_8, WS_PREFIX

构造器概要

构造器

限定符	构造器和说明
protected	TableObserverChannel(java.lang.String schematable, gu.sql2java.ListenerContainer<gu.sql2java.BaseBean> container)
protected	TableObserverChannel(java.lang.String schematable, gu.sql2java.ListenerContainer<gu.sql2java.BaseBean> container, gu.sql2java.RowMetaData rowMetaData)

方法概要

限定符和类型	方法和说明
void	onSubscribe(java.lang.String t)
boolean	registerListener(gu.sql2java.TableListener<gu.sql2java.BaseBean> listener) 注册侦听器
boolean	remove(gu.sql2java.TableListener<gu.sql2java.BaseBean> listener) 删除侦听器

从类继承的方法 gu.simplemq.Channel

addUnregistedListener, asMutable, clone, equals, equalsFull, getAdapter, getChannelNames, getChannelNames, getChannelNamesAsList, hashCode, immutable, onUnregisted, setAdapter, toString

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

finalize, getClass, notify, notifyAll, wait, wait, wait

构造器详细资料

TableObserverChannel

protected TableObserverChannel(java.lang.String schematable,
                               gu.sql2java.ListenerContainer<gu.sql2java.BaseBean> container)

TableObserverChannel

protected TableObserverChannel(java.lang.String schematable,
                               gu.sql2java.ListenerContainer<gu.sql2java.BaseBean> container,
                               gu.sql2java.RowMetaData rowMetaData)

方法详细资料

onSubscribe

public void onSubscribe(java.lang.String t)
                 throws gu.simplemq.exceptions.SmqUnsubscribeException

指定者:

onSubscribe 在接口中 gu.simplemq.IMessageAdapter<java.lang.String>

覆盖:

onSubscribe 在类中 gu.simplemq.Channel<java.lang.String>

抛出:

gu.simplemq.exceptions.SmqUnsubscribeException

registerListener

public boolean registerListener(gu.sql2java.TableListener<gu.sql2java.BaseBean> listener)

注册侦听器

参数:

listener -

返回:

注册成功返回true,listener为null或已经注册返回false,

remove

public boolean remove(gu.sql2java.TableListener<gu.sql2java.BaseBean> listener)

删除侦听器

参数:

listener -