net.neoremind.fountain.eventposition
类 AsyncFixedRateDisposeEventPosition

java.lang.Object
  net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition
      net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition

所有已实现的接口：

DisposeEventPosition

public class AsyncFixedRateDisposeEventPosition
extends AbstractProxyDisposeEventPosition
implements DisposeEventPosition

以固定的时间频率异步的存储同步点

作者：

zhangxu

字段摘要

从类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 继承的字段

delegate

构造方法摘要

AsyncFixedRateDisposeEventPosition()

方法摘要

void	destroy()
long	getInitDelayMs()
long	getPeriodMs()
void	init() 初始化
SyncPoint	loadSyncPoint() 这里简化下从prev中获取
void	registerInstance(String insName) 注册生产者实例的名称,在采用文件保存gt id时会使用该name作为文件名称
void	saveSyncPoint(SyncPoint point) 保存同步点
void	setDisposeEventPositionBridge(DisposeEventPositionBridge disposeEventPositionBridge)
void	setInitDelayMs(long initDelayMs)
void	setPeriodMs(long periodMs)

从类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 继承的方法

getDelegate, setDelegate

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

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

构造方法详细信息

AsyncFixedRateDisposeEventPosition

public AsyncFixedRateDisposeEventPosition()

方法详细信息

init

public void init()

初始化

destroy

public void destroy()

saveSyncPoint

public void saveSyncPoint(SyncPoint point)

从接口 DisposeEventPosition 复制的描述

保存同步点

指定者：

接口 DisposeEventPosition 中的 saveSyncPoint

参数：

point - SyncPoint

loadSyncPoint

public SyncPoint loadSyncPoint()

这里简化下从prev中获取

指定者：

接口 DisposeEventPosition 中的 loadSyncPoint

覆盖：

类 AbstractProxyDisposeEventPosition 中的 loadSyncPoint

返回：

SyncPoint

registerInstance

public void registerInstance(String insName)

从接口 DisposeEventPosition 复制的描述

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

指定者：

接口 DisposeEventPosition 中的 registerInstance

覆盖：

类 AbstractProxyDisposeEventPosition 中的 registerInstance

参数：

insName - producer实例名称

setDisposeEventPositionBridge

public void setDisposeEventPositionBridge(DisposeEventPositionBridge disposeEventPositionBridge)

getInitDelayMs

public long getInitDelayMs()

setInitDelayMs

public void setInitDelayMs(long initDelayMs)

getPeriodMs

public long getPeriodMs()

setPeriodMs

public void setPeriodMs(long periodMs)