接口 net.neoremind.fountain.eventposition.DisposeEventPosition
的使用

使用 DisposeEventPosition 的软件包

net.neoremind.fountain.eventposition

net.neoremind.fountain.eventposition 中 DisposeEventPosition 的使用

实现 DisposeEventPosition 的 net.neoremind.fountain.eventposition 中的类

class	AbstractProxyDisposeEventPosition 抽象的代理DisposeEventPosition
class	AsyncFixedRateDisposeEventPosition 以固定的时间频率异步的存储同步点
class	DelayGroupIdDisposeEventPosition 延迟一般一个、最多两个事务记录同步点，同步点必须是GroupIdSyncPoint
class	DelayGtIdDisposeEventPosition 不用延迟直接存储GtId，针对MySQL5.6本身会Server，fountain会传递自己的executed gtid set，以GtIdSet中的GtId.intervalStart和 GtId.intervalEnd表示，这里面GtId.intervalEnd是个开区间，最后一个点会重新下发。
class	LocalFileBinlogAndOffsetDisposeEventPosition 保存BinlogAndOffsetSyncPoint 类型syncpoint的实现
class	LocalFileDisposeEventPosition 采用本地文件来记录gt id的DisposeEventPosition 接口实现
class	LocalFileGtIdSetDisposeEventPosition 保存GtIdSyncPoint 类型syncpoint的实现
class	ReadonlyDisposeEventPosition 用于fountain-producer和fountaion-consumer在同一jvm中，producer使用该类只读取文件中 存储的gt id， 而不会记录gt id，记录gt id的行为交给consumer实现。
class	RegistableDisposeEventPosition 支持注册的DisposeEventPosition抽象实现

声明为 DisposeEventPosition 的 net.neoremind.fountain.eventposition 中的字段

protected DisposeEventPosition

AbstractProxyDisposeEventPosition.delegate

返回 DisposeEventPosition 的 net.neoremind.fountain.eventposition 中的方法

DisposeEventPosition	AbstractProxyDisposeEventPosition.getDelegate()
DisposeEventPosition	DisposeEventPositionBridgeImpl.getDisposeEventPosition(String producerName)
DisposeEventPosition	DisposeEventPositionBridge.getDisposeEventPosition(String producerName) 消费者根据producerName获取DisposeEventPosition对象来记录gt id

参数类型为 DisposeEventPosition 的 net.neoremind.fountain.eventposition 中的方法

void	DisposeEventPositionBridgeImpl.register(String producerName, DisposeEventPosition disp)
void	DisposeEventPositionBridge.register(String producerName, DisposeEventPosition disp) 生产者把自己的名称和所使用的 DisposeEventPosition注册进来
void	AbstractProxyDisposeEventPosition.setDelegate(DisposeEventPosition delegate)