接口 net.neoremind.fountain.changedata.BinlogTraceable
的使用

使用 BinlogTraceable 的软件包

net.neoremind.fountain.changedata
net.neoremind.fountain.common.mq

net.neoremind.fountain.changedata 中 BinlogTraceable 的使用

实现 BinlogTraceable 的 net.neoremind.fountain.changedata 中的类

class

ChangeDataSet 描述变化的数据的数据结构，类似jdbc的RowsSet，包括元数据和数据变化。

net.neoremind.fountain.common.mq 中 BinlogTraceable 的使用

返回 BinlogTraceable 的 net.neoremind.fountain.common.mq 中的方法

BinlogTraceable	FountainMQ.pop() 从队列中读取一个消息，如果队列中没有消息，则堵塞直到有一个消息进入
BinlogTraceable	AbstractMaxCapacityFountainMQ.pop()
BinlogTraceable	FountainMQ.pop(long timeout) 从队列中读取一个消息,支持超时版本，如果队列中没有消息，则堵塞直到有一个消息进入 或者超时，超时时返回false
BinlogTraceable	AbstractMaxCapacityFountainMQ.pop(long timeout)

参数类型为 BinlogTraceable 的 net.neoremind.fountain.common.mq 中的方法

protected int	MultiPermitsMemFountainMQ.getRequiredPermits(BinlogTraceable e)
protected int	MemFountainMQ.getRequiredPermits(BinlogTraceable e)
protected abstract int	AbstractMaxCapacityFountainMQ.getRequiredPermits(BinlogTraceable e) 从一个数据消息中获取需要权限的个数
void	FountainMQ.push(BinlogTraceable e) push一个消息，对于有界mq，如果容量已满，此方法会堵塞直到容量被至少是否一个unit
void	AbstractMaxCapacityFountainMQ.push(BinlogTraceable e)
boolean	FountainMQ.push(BinlogTraceable e, long timeout) push 一个消息，支持超时的版本，如果容量已满，此方法会堵塞直到容量被至少是否一个unit 或者超时，超时时返回false
boolean	AbstractMaxCapacityFountainMQ.push(BinlogTraceable e, long timeout)