程序包 | 说明 |
---|---|
com.alicloud.openservices.tablestore.tunnel.worker |
限定符和类型 | 类和说明 |
---|---|
class |
DefaultChannelProcessor |
限定符和类型 | 方法和说明 |
---|---|
IChannelProcessor |
ChannelProcessFactory.createProcessor(String tunnelId,
String clientId,
String channelId,
ICheckpointer checkpointer) |
IChannelProcessor |
IChannelProcessorFactory.createProcessor(String tunnelId,
String clientId,
String channelId,
ICheckpointer checkpointer) |
IChannelProcessor |
TunnelWorkerConfig.getChannelProcessor() |
IChannelProcessor |
ChannelConnect.getProcessor() |
限定符和类型 | 方法和说明 |
---|---|
IChannelConnect |
ChannelDialer.channelDial(String tunnelId,
String clientId,
String channelId,
String token,
IChannelProcessor processor,
TunnelStateMachine stateMachine) |
IChannelConnect |
IChannelDialer.channelDial(String tunnelId,
String clientId,
String channelId,
String token,
IChannelProcessor processor,
TunnelStateMachine state) |
void |
TunnelWorkerConfig.setChannelProcessor(IChannelProcessor channelProcessor) |
void |
ChannelConnect.setProcessor(IChannelProcessor processor) |
构造器和说明 |
---|
DefaultChannelProcessor(IChannelProcessor recordProcessor,
ICheckpointer checkpointer,
long checkpointIntervalInMillis) |
TunnelWorkerConfig(IChannelProcessor processor) |
TunnelWorkerConfig(ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor,
IChannelProcessor processor) |
Copyright © 2019. All Rights Reserved.