public class ClientRunningMonitor
extends com.alibaba.otter.canal.common.AbstractCanalLifeCycle
构造器和说明 |
---|
ClientRunningMonitor() |
限定符和类型 | 方法和说明 |
---|---|
boolean |
check()
检查当前的状态
|
void |
initRunning() |
boolean |
releaseRunning() |
void |
setClientData(ClientRunningData clientData) |
void |
setDelayTime(int delayTime) |
void |
setDestination(String destination) |
void |
setListener(ClientRunningListener listener) |
void |
setZkClient(com.alibaba.otter.canal.common.zookeeper.ZkClientx zkClient) |
void |
start() |
void |
stop() |
void |
waitForActive()
阻塞等待自己成为active,如果自己成为active,立马返回
|
public void start()
start
在接口中 com.alibaba.otter.canal.common.CanalLifeCycle
start
在类中 com.alibaba.otter.canal.common.AbstractCanalLifeCycle
public void stop()
stop
在接口中 com.alibaba.otter.canal.common.CanalLifeCycle
stop
在类中 com.alibaba.otter.canal.common.AbstractCanalLifeCycle
public void initRunning()
public void waitForActive() throws InterruptedException
public boolean check()
public boolean releaseRunning()
public void setListener(ClientRunningListener listener)
public void setDestination(String destination)
public void setClientData(ClientRunningData clientData)
public void setDelayTime(int delayTime)
public void setZkClient(com.alibaba.otter.canal.common.zookeeper.ZkClientx zkClient)
Copyright © 2013. All rights reserved.