public interface ClientChannel extends Channel, ClientSessionHolder
Modifier and Type | Interface and Description |
---|---|
static class |
ClientChannel.Streaming |
AttributeRepository.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
clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute
attributeKeys, getAttribute, getAttributesCount, ofAttributesMap, ofKeyValuePair
writePacket
getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
getClientSession
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–2022 The Apache Software Foundation. All rights reserved.