Package org.apache.sshd.client.channel

Interface ClientChannel

All Superinterfaces:

AttributeRepository, AttributeStore, java.lang.AutoCloseable, java.nio.channels.Channel, Channel, ChannelListenerManager, ChannelStreamWriterResolver, ChannelStreamWriterResolverManager, ClientSessionHolder, java.io.Closeable, Closeable, PropertyResolver, SessionContextHolder, SessionHolder<Session>, StreamingChannel

All Known Implementing Classes:

AbstractClientChannel, AgentForwardedChannel, ChannelDirectTcpip, ChannelExec, ChannelForwardedX11, ChannelSession, ChannelShell, ChannelSubsystem, DefaultSftpClient.SftpChannelSubsystem, PtyCapableChannelSession, TcpipClientChannel

public interface ClientChannel
extends Channel, StreamingChannel, ClientSessionHolder

A client channel used to communicate with the SSH server. Client channels can be shells, simple commands or subsystems. Note: client channels may be associated with a server session if they are opened by the server - e.g., for agent proxy, port forwarding, etc..

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.sshd.common.AttributeRepository

AttributeRepository.AttributeKey<T>

Nested classes/interfaces inherited from interface org.apache.sshd.common.channel.StreamingChannel

StreamingChannel.Streaming

Field Summary

Fields inherited from interface org.apache.sshd.common.channel.Channel

CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM

Fields inherited from interface org.apache.sshd.common.channel.throttle.ChannelStreamWriterResolver

NONE

Fields inherited from interface org.apache.sshd.common.PropertyResolver

EMPTY

Method Summary

Modifier and Type	Method	Description
IoInputStream	getAsyncErr()
IoOutputStream	getAsyncIn()
IoInputStream	getAsyncOut()
java.util.Set<ClientChannelEvent>	getChannelState()
java.lang.String	getChannelType()
default ClientSession	getClientSession()
java.lang.String	getExitSignal()
java.lang.Integer	getExitStatus()
java.io.InputStream	getInvertedErr()
java.io.OutputStream	getInvertedIn()	Access to an output stream to send data directly to the remote channel.
java.io.InputStream	getInvertedOut()
OpenFuture	open()
void	setErr(java.io.OutputStream err)
void	setIn(java.io.InputStream in)	Set an input stream that will be read by this channel and forwarded to the remote channel.
void	setOut(java.io.OutputStream out)
static void	validateCommandExitStatusCode(java.lang.String command, java.lang.Integer exitStatus)	Makes sure remote command exit status has been provided and it is zero
java.util.Set<ClientChannelEvent>	waitFor(java.util.Collection<ClientChannelEvent> mask, long timeout)	Waits until any of the specified events in the mask is signaled
default java.util.Set<ClientChannelEvent>	waitFor(java.util.Collection<ClientChannelEvent> mask, java.time.Duration timeout)	Waits until any of the specified events in the mask is signaled

Methods inherited from interface org.apache.sshd.common.AttributeRepository

attributeKeys, getAttribute, getAttributesCount

Methods inherited from interface org.apache.sshd.common.AttributeStore

clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute

Methods inherited from interface org.apache.sshd.common.channel.Channel

addRequestHandler, addRequestHandlers, getId, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, handleChannelRegistrationResult, handleChannelUnregistration, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleOpenFailure, handleOpenSuccess, handleRequest, handleSuccess, handleWindowAdjust, init, isEofSignalled, isInitialized, open, removeRequestHandler, removeRequestHandlers, resolveAttribute, writePacket

Methods inherited from interface org.apache.sshd.common.channel.ChannelListenerManager

addChannelListener, getChannelListenerProxy, removeChannelListener

Methods inherited from interface org.apache.sshd.common.channel.throttle.ChannelStreamWriterResolverManager

getChannelStreamWriterResolver, resolveChannelStreamWriter, resolveChannelStreamWriterResolver, setChannelStreamWriterResolver

Methods inherited from interface org.apache.sshd.common.Closeable

addCloseFutureListener, close, close, isClosed, isClosing, isOpen, removeCloseFutureListener

Methods inherited from interface org.apache.sshd.common.PropertyResolver

getBoolean, getBooleanProperty, getCharset, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty, isEmpty

Methods inherited from interface org.apache.sshd.common.session.SessionHolder

getSession, getSessionContext

Methods inherited from interface org.apache.sshd.common.channel.StreamingChannel

getStreaming, setStreaming

Method Detail

getClientSession

default ClientSession getClientSession()

Specified by:

getClientSession in interface ClientSessionHolder

Returns:

The underlying ClientSession used

getChannelType

java.lang.String getChannelType()

Returns:

The type of channel reported when it was created

getAsyncIn

IoOutputStream getAsyncIn()

getAsyncOut

IoInputStream getAsyncOut()

getAsyncErr

IoInputStream getAsyncErr()

getInvertedIn

java.io.OutputStream getInvertedIn()

Access to an output stream to send data directly to the remote channel. This can be used instead of using setIn(java.io.InputStream) method and having the channel polling for data in that stream.

Returns:

an OutputStream to be used to send data

getInvertedOut

java.io.InputStream getInvertedOut()

getInvertedErr

java.io.InputStream getInvertedErr()

setIn

void setIn(java.io.InputStream in)

Set an input stream that will be read by this channel and forwarded to the remote channel. Note that using such a stream will create an additional thread for pumping the stream which will only be able to end when that stream is actually closed or some data is read. It is recommended to use the getInvertedIn() method instead and write data directly.

Parameters:

in - an InputStream to be polled and forwarded

setOut

void setOut(java.io.OutputStream out)

setErr

void setErr(java.io.OutputStream err)

open

OpenFuture open()
         throws java.io.IOException

Throws:

java.io.IOException

getChannelState

java.util.Set<ClientChannelEvent> getChannelState()

Returns:

A snapshot of the current channel state

See Also:

waitFor(Collection, long)

waitFor

java.util.Set<ClientChannelEvent> waitFor(java.util.Collection<ClientChannelEvent> mask,
                                          long timeout)

Waits until any of the specified events in the mask is signaled

Parameters:

mask - The ClientChannelEvents mask

timeout - The timeout to wait (msec.) - if non-positive then forever

Returns:

The actual signaled event - includes ClientChannelEvent.TIMEOUT if timeout expired before the expected event was signaled

waitFor

default java.util.Set<ClientChannelEvent> waitFor(java.util.Collection<ClientChannelEvent> mask,
                                                  java.time.Duration timeout)

Waits until any of the specified events in the mask is signaled

Parameters:

mask - The ClientChannelEvents mask

timeout - The timeout to wait - if null then forever

Returns:

The actual signaled event - includes ClientChannelEvent.TIMEOUT if timeout expired before the expected event was signaled

getExitStatus

java.lang.Integer getExitStatus()

Returns:

The signaled exit status via "exit-status" request - null if not signaled

getExitSignal

java.lang.String getExitSignal()

Returns:

The signaled exit signal via "exit-signal" - null if not signaled

validateCommandExitStatusCode

static void validateCommandExitStatusCode(java.lang.String command,
                                          java.lang.Integer exitStatus)
                                   throws java.rmi.RemoteException

Makes sure remote command exit status has been provided and it is zero

Parameters:

command - The command string - used only for exception text

exitStatus - The exit status value

Throws:

java.rmi.RemoteException - If exitStatus is null or non-zero