net.neoremind.fountain.eventposition
接口 DisposeEventPosition

所有已知实现类:
AbstractProxyDisposeEventPosition, AsyncFixedRateDisposeEventPosition, DelayGroupIdDisposeEventPosition, DelayGtIdDisposeEventPosition, LocalFileBinlogAndOffsetDisposeEventPosition, LocalFileDisposeEventPosition, LocalFileGtIdSetDisposeEventPosition, ReadonlyDisposeEventPosition, RegistableDisposeEventPosition

public interface DisposeEventPosition

保存最后一个处理的mysql 事件所对应的gt id,重启或者数据源崩溃时从该id继续恢复数据读取。

作者:
hexiufeng, zhangxu

方法摘要
 SyncPoint loadSyncPoint()
          加载同步点
 void registerInstance(String insName)
          注册生产者实例的名称,在采用文件保存gt id时会使用该name作为文件名称
 void saveSyncPoint(SyncPoint point)
          保存同步点
 

方法详细信息

registerInstance

void registerInstance(String insName)
注册生产者实例的名称,在采用文件保存gt id时会使用该name作为文件名称

参数:
insName - producer实例名称

loadSyncPoint

SyncPoint loadSyncPoint()
加载同步点

返回:
SyncPoint对象

saveSyncPoint

void saveSyncPoint(SyncPoint point)
保存同步点

参数:
point - SyncPoint


Copyright © 2016 neoremind. All rights reserved.