public class TunnelStateMachine extends Object
构造器和说明 |
---|
TunnelStateMachine(String tunnelId,
String clientId,
IChannelDialer dialer,
IChannelProcessorFactory processorFactory,
TunnelClientInterface client) |
限定符和类型 | 方法和说明 |
---|---|
List<IChannelConnect> |
batchGetChannelConnects() |
List<com.alicloud.openservices.tablestore.model.tunnel.internal.Channel> |
batchGetChannels() |
void |
batchUpdateChannels(List<com.alicloud.openservices.tablestore.model.tunnel.internal.Channel> batchChannels) |
void |
close() |
void |
updateStatus(com.alicloud.openservices.tablestore.model.tunnel.internal.Channel channel)
更新StateMachine中的活跃Channel信息,同时移除(ChannelId相同的)处于Closed状态的ChannelConnect.
|
public TunnelStateMachine(String tunnelId, String clientId, IChannelDialer dialer, IChannelProcessorFactory processorFactory, TunnelClientInterface client)
public void updateStatus(com.alicloud.openservices.tablestore.model.tunnel.internal.Channel channel)
channel
- public List<IChannelConnect> batchGetChannelConnects()
public List<com.alicloud.openservices.tablestore.model.tunnel.internal.Channel> batchGetChannels()
public void batchUpdateChannels(List<com.alicloud.openservices.tablestore.model.tunnel.internal.Channel> batchChannels)
public void close()
Copyright © 2019. All Rights Reserved.