public class ChannelConnect extends Object implements IChannelConnect
TunnelStateMachine的说明。| Constructor and Description |
|---|
ChannelConnect() |
public void notifyStatus(com.alicloud.openservices.tablestore.model.tunnel.internal.Channel channel)
IChannelConnectnotifyStatus in interface IChannelConnectpublic void checkAndUpdateChannelStatus()
public boolean closed()
IChannelConnectclosed in interface IChannelConnectpublic void close()
IChannelConnectclose in interface IChannelConnectpublic void close(boolean finish)
public String getTunnelId()
public void setTunnelId(String tunnelId)
public String getClientId()
public void setClientId(String clientId)
public String getChannelId()
public void setChannelId(String channelId)
public String getToken()
public void setToken(String token)
public TunnelClientInterface getClient()
public void setClient(TunnelClientInterface client)
public IChannelProcessor getProcessor()
public void setProcessor(IChannelProcessor processor)
public com.alicloud.openservices.tablestore.model.tunnel.internal.Channel getCurrentChannel()
public void setCurrentChannel(com.alicloud.openservices.tablestore.model.tunnel.internal.Channel currentChannel)
public TunnelStateMachine getStateMachine()
public void setStateMachine(TunnelStateMachine stateMachine)
public ChannelConnectStatus getStatus()
public void setStatus(ChannelConnectStatus status)
public AtomicBoolean getFinished()
public void setFinished(AtomicBoolean finished)
public boolean isStreamChannel()
public void setStreamChannel(boolean streamChannel)
public ICheckpointer getCheckpointer()
public void setCheckpointer(ICheckpointer checkpointer)
public ProcessDataPipeline getProcessPipeline()
public void setProcessPipeline(ProcessDataPipeline processPipeline)
public ExecutorService getChannelExecutorService()
public void setChannelExecutorService(ExecutorService channelExecutorService)
Copyright © 2024. All Rights Reserved.