public class ChannelConnect extends Object implements IChannelConnect
TunnelStateMachine
的说明。构造器和说明 |
---|
ChannelConnect() |
public void notifyStatus(com.alicloud.openservices.tablestore.model.tunnel.internal.Channel channel)
IChannelConnect
notifyStatus
在接口中 IChannelConnect
public void checkAndUpdateChannelStatus()
public boolean closed()
IChannelConnect
closed
在接口中 IChannelConnect
public void close()
IChannelConnect
close
在接口中 IChannelConnect
public 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 © 2019. All Rights Reserved.