public class TunnelWorkerConfig extends Object
构造器和说明 |
---|
TunnelWorkerConfig() |
TunnelWorkerConfig(IChannelProcessor processor) |
TunnelWorkerConfig(ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor,
IChannelProcessor processor) |
public TunnelWorkerConfig()
public TunnelWorkerConfig(IChannelProcessor processor)
public TunnelWorkerConfig(ThreadPoolExecutor readRecordsExecutor, ThreadPoolExecutor processRecordsExecutor, 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 int getMaxRetryIntervalInMillis()
public void setMaxRetryIntervalInMillis(int maxRetryIntervalInMillis)
public static ThreadPoolExecutor newDefaultThreadPool(String threadPrefix)
threadPrefix:
- 线程名称的前缀标识public int getMaxChannelParallel()
public void setMaxChannelParallel(int maxChannelParallel)
public void setChannelHelperExecutor(ThreadPoolExecutor channelHelperExecutor)
public ThreadPoolExecutor getChannelHelperExecutor()
public void shutdown()
Copyright © 2019. All Rights Reserved.