xin.manong.weapon.aliyun.ots

类 OTSTunnel

java.lang.Object

xin.manong.weapon.aliyun.ots.OTSTunnel

所有已实现的接口:

Rebuildable

public class OTSTunnel
extends Object
implements Rebuildable

OTS数据通道

作者:

frankcl

字段概要

字段

限定符和类型	字段和说明
protected AlarmSender	alarmSender
protected String	appName
protected OTSTunnelConfig	config
protected OTSTunnelMonitor	monitor
protected List<RebuildListener>	rebuildListeners
protected com.alicloud.openservices.tablestore.TunnelClient	tunnelClient
protected Map<String,OTSTunnelWorker>	workerMap

构造器概要

构造器

构造器和说明
OTSTunnel(OTSTunnelConfig config)

方法概要

限定符和类型	方法和说明
void	addRebuildListener(RebuildListener listener) 添加重建监听器
void	rebuild()
void	setAlarmSender(AlarmSender alarmSender) 设置报警发送器
void	setAppName(String appName) 设置所属应用名
boolean	start() 启动OTS通道
boolean	startTunnelWorker(OTSTunnelWorkerConfig workerConfig) 启动通道worker
void	stop() 停止OTS通道
void	stopTunnelWorker(OTSTunnelWorkerConfig workerConfig) 停止通道worker

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

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

字段详细资料

appName

protected String appName

config

protected OTSTunnelConfig config

monitor

protected OTSTunnelMonitor monitor

tunnelClient

protected com.alicloud.openservices.tablestore.TunnelClient tunnelClient

workerMap

protected Map<String,OTSTunnelWorker> workerMap

rebuildListeners

protected List<RebuildListener> rebuildListeners

alarmSender

protected AlarmSender alarmSender

构造器详细资料

OTSTunnel

public OTSTunnel(OTSTunnelConfig config)

方法详细资料

rebuild

public void rebuild()

指定者:

rebuild 在接口中 Rebuildable

start

public boolean start()

启动OTS通道

返回:

启动成功返回true，否则返回false

stop

public void stop()

停止OTS通道

addRebuildListener

public void addRebuildListener(RebuildListener listener)

添加重建监听器

参数:

listener - 重建监听器

startTunnelWorker

public boolean startTunnelWorker(OTSTunnelWorkerConfig workerConfig)

启动通道worker

参数:

workerConfig - 通道worker配置

返回:

启动成功返回true，否则返回false

stopTunnelWorker

public void stopTunnelWorker(OTSTunnelWorkerConfig workerConfig)

停止通道worker

参数:

workerConfig - 通道worker配置

setAlarmSender

public void setAlarmSender(AlarmSender alarmSender)

设置报警发送器

参数:

alarmSender - 报警发送器

setAppName

public void setAppName(String appName)

设置所属应用名

参数:

appName - 所属应用名