| Package | Description |
|---|---|
| com.alicloud.openservices.tablestore.tunnel.worker |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultChannelProcessor |
| Modifier and Type | Method and Description |
|---|---|
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() |
| Modifier and Type | Method and Description |
|---|---|
IChannelConnect |
IChannelDialer.channelDial(String tunnelId,
String clientId,
String channelId,
String token,
IChannelProcessor processor,
TunnelStateMachine state) |
IChannelConnect |
ChannelDialer.channelDial(String tunnelId,
String clientId,
String channelId,
String token,
IChannelProcessor processor,
TunnelStateMachine stateMachine) |
void |
TunnelWorkerConfig.setChannelProcessor(IChannelProcessor channelProcessor) |
void |
ChannelConnect.setProcessor(IChannelProcessor processor) |
| Constructor and Description |
|---|
DefaultChannelProcessor(IChannelProcessor recordProcessor,
ICheckpointer checkpointer,
long checkpointIntervalInMillis) |
TunnelWorkerConfig(IChannelProcessor processor) |
TunnelWorkerConfig(ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor,
IChannelProcessor processor) |
Copyright © 2024. All Rights Reserved.