public interface ClientChannel extends Channel
Modifier and Type | Interface and Description |
---|---|
static class |
ClientChannel.Streaming |
AttributeStore.AttributeKey<T>
CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM
EMPTY
NONE
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
addRequestHandler, addRequestHandlers, getId, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, getSession, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleOpenFailure, handleOpenSuccess, handleRequest, handleSuccess, handleWindowAdjust, init, isEofSignalled, isInitialized, open, removeRequestHandler, removeRequestHandlers, resolveAttribute, resolveAttribute
addChannelListener, getChannelListenerProxy, removeChannelListener
getBoolean, getBooleanProperty, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty
getAttribute, removeAttribute, setAttribute
writePacket
getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
String getChannelType()
ClientChannel.Streaming getStreaming()
void setStreaming(ClientChannel.Streaming streaming)
IoOutputStream getAsyncIn()
IoInputStream getAsyncOut()
IoInputStream getAsyncErr()
OutputStream getInvertedIn()
setIn(java.io.InputStream)
method
and having the channel polling for data in that stream.InputStream getInvertedOut()
InputStream getInvertedErr()
void setIn(InputStream in)
getInvertedIn()
method instead and write data directly.in
- an InputStream to be polled and forwardedvoid setOut(OutputStream out)
void setErr(OutputStream err)
OpenFuture open() throws IOException
IOException
Set<ClientChannelEvent> getChannelState()
waitFor(Collection, long)
Set<ClientChannelEvent> waitFor(Collection<ClientChannelEvent> mask, long timeout)
mask
- The ClientChannelEvent
s masktimeout
- The timeout to wait (msec.) - if non-positive then foreverClientChannelEvent.TIMEOUT
if timeout expired before the expected event was signaledInteger getExitStatus()
null
if not signaledString getExitSignal()
null
if not signaledstatic void validateCommandExitStatusCode(String command, Integer exitStatus) throws RemoteException
command
- The command string - used only for exception textexitStatus
- The exit status valueRemoteException
- If exitStatus is null
or non-zeroCopyright © 2008–2018 The Apache Software Foundation. All rights reserved.