public class TunnelWorkerConfig extends Object
构造器和说明 |
---|
TunnelWorkerConfig(IChannelProcessor processor) |
限定符和类型 | 方法和说明 |
---|---|
IChannelProcessor |
getChannelProcessor() |
long |
getCheckpointIntervalInMillis() |
String |
getClientTag() |
long |
getHeartbeatIntervalInSec() |
long |
getHeartbeatTimeoutInSec() |
ThreadPoolExecutor |
getProcessRecordsExecutor() |
ThreadPoolExecutor |
getReadRecordsExecutor() |
void |
setChannelProcessor(IChannelProcessor channelProcessor) |
void |
setCheckpointIntervalInMillis(long checkpointIntervalInMillis) |
void |
setClientTag(String clientTag) |
void |
setHeartbeatIntervalInSec(long heartbeatIntervalInSec) |
void |
setHeartbeatTimeoutInSec(long heartbeatTimeoutInSec) |
void |
setProcessRecordsExecutor(ThreadPoolExecutor processRecordsExecutor) |
void |
setReadRecordsExecutor(ThreadPoolExecutor readRecordsExecutor) |
void |
shutdown()
回收线程池资源。
|
public TunnelWorkerConfig(IChannelProcessor processor)
public long getHeartbeatTimeoutInSec()
public void setHeartbeatTimeoutInSec(long heartbeatTimeoutInSec)
public long getHeartbeatIntervalInSec()
public void setHeartbeatIntervalInSec(long heartbeatIntervalInSec)
public String getClientTag()
public void setClientTag(String clientTag)
public IChannelProcessor getChannelProcessor()
public void setChannelProcessor(IChannelProcessor channelProcessor)
public long getCheckpointIntervalInMillis()
public void setCheckpointIntervalInMillis(long checkpointIntervalInMillis)
public ThreadPoolExecutor getReadRecordsExecutor()
public void setReadRecordsExecutor(ThreadPoolExecutor readRecordsExecutor)
public ThreadPoolExecutor getProcessRecordsExecutor()
public void setProcessRecordsExecutor(ThreadPoolExecutor processRecordsExecutor)
public void shutdown()
Copyright © 2019. All Rights Reserved.